MapReduce 在服务器上运行

2021-11-19  本文已影响0人  V_6619

代码首先在本地测试成功后

需要改写一些,首先把输入输出改成 args[0] args[1]
如下:

FileInputFormat.setInputPaths(job, new Path(args[0]));
FileOutputFormat.setOutputPath(job, new Path(args[1]));
 mvn clean package -DskinTests

如果遇到mvn commond not found
执行

source ~/.bash_profile

编写脚本

hadoop jar /home/hadoop/lib/hadoop-train-v2-1.0.jar com.imooc.bigdata.hadoop.mr.project.mrServer.PageStatServerApp hdfs://hadoop000:8020/project/input/raw/ hdfs://hadoop000:8020/project/output/v1/pvstat/
上一篇下一篇

猜你喜欢

热点阅读