自己写的MapReduce程序运行问题

作者：我家自动化 | 2024-08-13 22:03:35

踩

自己写的MapReduce程序运行问题

出现这个问题主要是调用的问题，没有加入包
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 // --查看输出结果

声明：本文内容由网友自发贡献，转载请注明出处：【wpsshop博客】