运行使用zooKeeper的MapReduce代码

Question

我想问一下如何执行使用zooKeeper的MapReduce java代码。

我的第一个代码是创建一个变量（znode）并通过每个映射器对其进行修改。 所以我修改了wordCount代码，以便第一次测试zookeeper。 当我运行它使用Eclipse控制台，一切顺利的话，这样我就可以执行它使用Linux命令行上看到Z序节点的价值变动等

不过，我是想：

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

我

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

虽然我使用conf.set（ “mapred.jar”， “......”）中加入的jar文件的路径下面的错误;在mapreduce代码中，但我不知道为什么它没有识别zookeeper的类。

有什么想法？

Answer 1

检查this Cloudera的博客，关于如何在MR作业中包含第三方库。