尝试运行camus时发生java.lang.classnotfoundexception

h9a6wy2h  于 2021-05-30  发布在  Hadoop
关注(0)|答案(1)|浏览(356)

我下载了包含camus jars的confluent包,并按照联机说明在此处输入链接描述。
hadoop是正确设置的(这意味着我可以使用HadoopFS-ls命令和其他HadoopJAR命令)。然而,当我试图逃跑时

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

我得到了“主”类NotFound错误

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服务不是为了运行它。
有人有类似的问题吗?
谢谢。

ryevplcw

ryevplcw1#

您应该尝试检查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}

相关问题