现在的位置: 首页 > 综合 > 正文

自己写的MapReduce程序运行问题

2018年11月07日 ⁄ 综合 ⁄ 共 901字 ⁄ 字号 评论关闭

Exception
in thread "main" java.lang.ClassNotFoundException: WordCount

出现这个问题主要是调用的问题,没有加入包
bin/hadoop jar wordcount.jar WordCount wc_input wc_output

改成如下的样子就可以了

bin/hadoop jar wordcount.jar com.hadoop.WordCount wc_input wc_output


整个过程的commander如下,仅供参考,环境是Hadoop集群XShell:

rz                 // -- 上传WordCount.java 和file*.txt   (rm, mv, rm -rf 删除目录)

全部操作都在对应版本的Hadoop文件夹中!例如我是在hadoop-1.0.4下(囧,集群最高版本就是这个了...)
bin/hadoop fs -mkdir input                             // -- 新建input文件夹,并将file*.txt mv进去
bin/hadoop fs -put input/file* wc_input       // --将本地输入文件上传hdfs集群
mkdir WordCount                                           // --创建WordCount目录

javac -classpath hadoop-core-1.0.4.jar:lib/commons-cli-1.2.jar -d WordCount WordCount.java     
// --编译WordCount.java,结果放入WordCount目录

jar -cvf wordcount.jar -C WordCount .                         
// --将编译结果打成jar包  !!注意在WordCount后面有空格,然后还有一个"."!!

bin/hadoop jar wordcount.jar com.hadoop.WordCount wc_input wc_output            
// --在集群上运行,注意加入调用的包

bin/hadoop fs -cat wc_output/part-r-00000            // --查看输出结果

抱歉!评论已关闭.