0

camus jar を含むコンフルエント パッケージをダウンロードし、オンラインの指示に従って、ここにリンクの説明を入力します。

Hadoop が適切にセットアップされている (つまり、hadoop fs -ls コマンドおよびその他の hadoop jar コマンドを使用できる)。しかし、私が実行しようとしたとき

hadoop jar confluent-camus-1.0.jar com.linkedin.camus.etl.kafka.CamusJob

「メイン」のclassNotFoundエラーが発生しました

Exception in thread "main" java.lang.ClassNotFoundException: com.linkedin.camus.
etl.kafka.CamusJob
        at java.net.URLClassLoader$1.run(URLClassLoader.java:372)
        at java.net.URLClassLoader$1.run(URLClassLoader.java:361)
        at java.security.AccessController.doPrivileged(Native Method)
        at java.net.URLClassLoader.findClass(URLClassLoader.java:360)
        at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
        at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
        at java.lang.Class.forName0(Native Method)
        at java.lang.Class.forName(Class.java:344)
        at org.apache.hadoop.util.RunJar.main(RunJar.java:205)

「confluent-camus-1.0.jar」へのパスは正しいです (フォルダーのすぐ下)。実行しようとするためだけに、kafka サービスを開始しませんでした。

誰かが同様の問題を抱えていますか？

ありがとう。

4

1 に答える 1

0

jar ファイルを調べてみてください。

jar tvf confluent-camus-1.0.jar | grep com.linkedin.camus.etl.kafka.CamusJob

このクラスが見つからない場合は、camus によって生成された他の jar で検索してみてください。

ターゲットjarを追加する必要がある後

hadoop jar confluent-camus-1.0.jar com.linkedin.camus.etl.kafka.CamusJob -libjars {JAR_NAME}
于 2015-09-23T10:28:43.103 に答える