AnsweredAssumed Answered

mapreduce job failed

Question asked by satish on Dec 23, 2012
Latest reply on Apr 15, 2015 by nishant5s
Hi All,

I am beginner in hadoop and installed CDH4.1.2 on Ubuntu. I started all nodes and JPS command also shows all nodes without any issues. But when I try to run my first program I am getting below error.

I spent almost 2 weeks on this but no clue. I appreciate all the help if any one can help in resolving the problem.

    hadoop@ubuntu:/usr/local/hadoop/hadoop-2.0.0-mr1-cdh4.1.2$ jps
    9893 NameNode
    10371 SecondaryNameNode
    10726 TaskTracker
    10524 JobTracker
    10846 Jps
    10101 DataNode
    hadoop@ubuntu:/usr/local/hadoop/hadoop-2.0.0-mr1-cdh4.1.2$ hadoop jar /usr/local/hadoop/FirstHadoopProgram/target/FirstHadoopProgram-1.0-SNAPSHOT.jar org.apache.maven.archetypes.App /usr/local/hadoop/InputWordCount/file1 /usr/local/hadoop/InputWordCount/file2
    12/12/23 09:15:25 WARN fs.MapRFileSystem: Could not find any cluster, defaulting to localhost
    2012-12-23 09:15:25,5708 ERROR Client fs/client/fileclient/cc/client.cc:304 Thread: 140434478728960 Failed to initialize client for cluster 127.0.0.1:7222, error Connection reset by peer(104)
    12/12/23 09:15:25 ERROR ipc.RPC: FailoverProxy: Failing this Call: getStagingAreaDir. Error while fetching JobTracker location java.io.IOException: Failed to get cluster information for maprfs:///
    Exception in thread "main" java.io.IOException: Failed to get cluster information for maprfs:///
     at com.mapr.fs.MapRFileSystem.getJobTrackerAddrs(MapRFileSystem.java:1323)
     at org.apache.hadoop.ipc.RPC$FailoverInvoker.invoke(RPC.java:526)
     at org.apache.hadoop.mapred.$Proxy0.getStagingAreaDir(Unknown Source)
     at org.apache.hadoop.mapred.JobClient.getStagingAreaDir(JobClient.java:1287)
     at org.apache.hadoop.mapreduce.JobSubmissionFiles.getStagingDir(JobSubmissionFiles.java:102)
     at org.apache.hadoop.mapred.JobClient$2.run(JobClient.java:891)
     at org.apache.hadoop.mapred.JobClient$2.run(JobClient.java:885)
     at java.security.AccessController.doPrivileged(Native Method)
     at javax.security.auth.Subject.doAs(Subject.java:416)
     at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1127)
     at org.apache.hadoop.mapred.JobClient.submitJobInternal(JobClient.java:885)
     at org.apache.hadoop.mapred.JobClient.submitJob(JobClient.java:859)
     at org.apache.hadoop.mapred.JobClient.runJob(JobClient.java:1331)
     at org.apache.maven.archetypes.App.main(App.java:55)
     at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
     at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
     at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
     at java.lang.reflect.Method.invoke(Method.java:616)
     at org.apache.hadoop.util.RunJar.main(RunJar.java:197)

Outcomes