2016-07-25 8 views

答えて

1

あなたは、このコマンドを使用することができます: -

Hadoopのジャー{} path_to_jar /hadoop-streaming.jar -Dmapreduce.job.queuename =デフォルト-Dstream。/grep " - grep" -dmapred.reduce.tasks = 1 -input/tmp/{input_path} -output/tmp/{output_path} -mapper 'grep searchTerm '

+0

ありがとうございました!不思議なことに、Dstream.non.zero.exit.is.failure = falseはここで何をしたのですか? – ravi

+0

この検索キーワードが見つからない場合は、このマッパーは失敗します – sorabh

関連する問題