有 Java 编程相关的问题?

你可以在下面搜索框中键入要查询的问题!

java如何让“hadoop jar”命令获取同名jar的新版本

我是hadoop新手,我从hadoop 2.6.0开始就尝试了它的例子
首先,我重新编译了hadoop-mapreduce-examples-2.6.0.jar的源代码,并构建了一个新的jar文件MapReduce-0.0.1.jar

然后我用这个命令行运行了terasort示例

jjin:hadoop$ bin/hadoop jar ~/shared/MapReduce-0.0.1.jar terasort /input /output
15/01/07 12:27:44 INFO terasort.TeraSort: starting
15/01/07 12:27:46 INFO input.FileInputFormat: Total input paths to process : 1
...

完成terasort后,我通过如下修改第一行日志消息来更新TeraSort.java的源代码

public int run(String[] args) throws Exception {
LOG.info("starting..."); 
// Update log message by adding '...' to the end of previous one.
Job job = Job.getInstance(getConf());

但在重新运行这个terasort作业后,我发现日志消息没有变为“starting…”,所以这意味着我对TeraSort.java所做的更改不会生效

问题是如何让hadoop接受我构建的新的MapReduce-0.0.1.jar。 谢谢


共 (0) 个答案