2016-07-25 11 views

Antwort

1

Sie können diesen Befehl verwenden: -

hadoop jar {path_to_jar} /hadoop-streaming.jar -Dmapreduce.job.queuename = default -Dstream. non.zero.exit.is.failure = false -Dmap.job.name = "grepper" -Dmap.reduce.tasks = 1 -input/tmp/{eingabepfad} -output/tmp/{ausgabepfad} -mapper 'grep searchTerm '

+0

Danke, es hat funktioniert! Nur neugierig, was macht -Dstream.non.zero.exit.is.failure = false hier? – ravi

+0

Ohne diese Mapper wird fehlschlagen, wo dieser Suchbegriff nicht gefunden wird – sorabh