MapReduce Programming

19/10/07 07:49:17 INFO ipc.Client: Retrying connect to server: cxln2.c.thelab-240901.internal/10.142.1.2:8050. Already tried 24 time(s); retry policy is RetryUpToMaximumCountWithFixedSleep(maxRetries=50, sleepTime=1000 MILLISECONDS)19/10/07 07:49:18 INFO ipc.Client: Retrying connect to server: cxln2.c.thelab-240901.internal/10.142.1.2:8050. Already tried 25 time(s); retry policy is RetryUpToMaximumCountWithFixedSleep(maxRetries=50, sleepTime=1000 MILLISECONDS)19/10/07 07:49:19 INFO ipc.Client: Retrying connect to server: cxln2.c.thelab-240901.internal/10.142.1.2:8050. Already tried 26 time(s); retry policy is RetryUpToMaximumCountWithFixedSleep(maxRetries=50, sleepTime=1000 MILLISECONDS)
19/10/07 07:49:20 INFO ipc.Client: Retrying connect to server: cxln2.c.thelab-240901.internal/10.142.1.2:8050. Already tried 27 time(s); retry policy is RetryUpToMaximumCountWithFixedSleep(maxRetries=50, sleepTime=1000 MILLISECONDS)19/10/07 07:49:21 INFO ipc.Client: Retrying connect to server: cxln2.c.thelab-240901.internal/10.142.1.2:8050. Already tried 28 time(s); retry policy is RetryUpToMaximumCountWithFixedSleep(maxRetries=50, sleepTime=1000 MILLISECONDS)
19/10/07 07:49:22 INFO ipc.Client: Retrying connect to server: cxln2.c.thelab-240901.internal/10.142.1.2:8050. Already tried 29 time(s); retry policy is RetryUpToMaximumCountWithFixedSleep(maxRetries=50, sleepTime=1000 MILLISECONDS)

Assignment:
MapReduce Programming - Count the frequency of characters in a file stored in HDFS

Please help me into this??

Hi, S.R_Shinde.
Can you please try it again,the error seems to be server connection ip problem as the it got changed to 2.6.2.0-205.

Please try to see the below command, it worked for me.

hadoop jar /usr/hdp/2.6.2.0-205/hadoop-mapreduce/hadoop-streaming.jar -input /data/mr/wordcount/big.txt -output m
apreduce-programming/character_frequency -mapper mapper.py -file mapper.py -reducer reducer.py -file reducer.py

Feel free to reply to this thread if any problem. All the best.

1 Like