0

我正在尝试编写一个 shell 脚本,该脚本将在伪分布式集群上执行 Hadoop MapReduce 作业,但省略所有前面没有!的输出。我尝试将输出通过管道传输到 awk 并以这种方式对其进行过滤,这适用于大多数输出​​,但我仍然将输出从 JobClient 获取到终端。有没有办法防止这种情况?

我的代码目前如下所示:

#!/bin/sh

runtimes=$1

for i in {0..$runtimes}
do
  cd ~/Documents/hadoop-1.0.3
  bin/hadoop dfs -rmr /SC_out | awk "{}"
  bin/hadoop jar ../MapReduceTests/SyntaxCounter.jar mrt.SyntaxCounter /WC_in/ /SC_out/ | awk "{}"
  bin/hadoop dfs -cat /SC_out/part* | awk "\$0~/!Map/ {print \$0}"
done

编辑:这是我想要压制的那种输出:

12/08/15 16:45:17 INFO mapred.JobClient: Running job: job_201208151042_0128
12/08/15 16:45:18 INFO mapred.JobClient:  map 0% reduce 0%
12/08/15 16:45:31 INFO mapred.JobClient:  map 100% reduce 0%
12/08/15 16:45:43 INFO mapred.JobClient:  map 100% reduce 100%
4

1 回答 1

1

这个输出在stderr,不是std out,所以修改如下:

bin/hadoop jar ../MapReduceTests/SyntaxCounter.jar mrt.SyntaxCounter \
    /WC_in/ /SC_out/  2>/dev/null | awk "{}"

或者更简单地说,调用带有详细参数设置为 false 的作业:

job.waitForCompletion(false);
于 2012-08-16T18:44:55.867 回答