MapReduce in Python error


2 Answer(s)


Hi Pramod,

Please download the jar again from the following link:
http://www.java2s.com/Code/Jar/h/Downloadhadoopstreamingjar.htm

Note: You don't need to mention python in the mapper and reducer.
Check the link for the reference: https://hadoop.apache.org/docs/r1.2.1/streaming.html

Let me know if you are getting the same error again:
Error:

java.lang.ClassNotFoundException: Class org.apache.hadoop.streaming.PipeMapRunner not found

 

Hope this helps. Thanks


Hi Thanks for the reply.

It appears this example was not running as expected in cloudera 4.4 version.

I downloaded newer version 5.13 and to my surprise every is working as expected.

Thanks a lot.