java.lang.ClassNotFoundException при попытке запустить camus

Question

Я загрузил конфлюентный пакет, который включает в себя банку с камнем, и я выполнил инструкции онлайн enter link description here.

Hadoop правильно настроен (это означает, что я могу использовать команды hadoop fs -ls и другие команды jaro jaoop). Однако, когда я попытался запустить

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) 

путь к «сливающийся-Камю-1.0.jar» правильно (справа в папке) , Я не запустил сервис kafka, просто попытался запустить его.

У кого-то были проблемы?

Спасибо.

Answer 1

Вы должны попытаться проверить ваш файл фляги:

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

Если вы не можете найти этот класс, попытайтесь найти его в другом банке, который генерировал Камю.

После необходимо добавить целевой банку с

hadoop jar confluent-camus-1.0.jar com.linkedin.camus.etl.kafka.CamusJob -libjars {JAR_NAME}