运行mapreduce代码,使用zookeeper

relj7zay  于 2021-06-04  发布在  Hadoop
关注(0)|答案(0)|浏览(202)

我想问一下如何执行使用zookeeper的MapReduceJava代码。
我的第一个代码只是创建一个变量(znode)并由每个Map器修改它。所以我第一次修改了wordcount代码来测试zookeeper。当我使用eclipse控制台运行它时,一切都很顺利,所以我可以看到znode值的变化,等等。
但是,我尝试使用linux命令行执行它:


**bin/hadoop jar ./myjar.jar algo.WordCount /input.txt /out

我犯了以下错误


**Error: java.lang.ClassNotFoundException: org.apache.zookeeper.Watcher

尽管我使用conf.set(“mapred.jar”,“…”)添加了jar文件的路径;但是我不知道为什么它不能识别zookeeper的类。
你知道吗?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题