我想问一下如何执行使用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的类。
你知道吗?
暂无答案!
目前还没有任何答案,快来回答吧!