Support Questions
Find answers, ask questions, and share your expertise

Launcher ERROR, reason: Main class [org.apache.oozie.action.hadoop.PigMain], exit code [2]

Explorer

I am trying to run the UpperText example that comes with HUE and I am getting this error from Oozie every time:

 

JA018 -- Main class [org.apache.oozie.action.hadoop.PigMain], exit code [2] -- Kill

 

The Job Browser lists the job as successful but the workflow shows status Kill with the above error.

 

This is a manual installation and the only things running are Hadoop, Oozie and HUE. No other apps or services are running.

 

So far the only thing I could come up with is that JA018 in the Oozie documentation is listed as "JA018 is output directory exists error in workflow map-reduce action" but I have no clue what this means. I am giving a new directory and file as output in the example.

 

I have set the libpath in oozie-site and I have also enabled adding the libpath to the jobs by default. Hadoop seems to be doing its jobs as there is no error in the logs. It is Oozie that is having problems.

 

Can anyone help me understand and troubleshoot this problem?

 

2015-05-20 08:50:42,950  INFO ActionStartXCommand:541 - SERVER[TestPi2] USER[pi] GROUP[-] TOKEN[] APP[pig-app-hue-script] JOB[0000000-150520084715937-oozie-pi-W] ACTION[0000000-150520084715937-oozie-pi-W@:start:] Start action [0000000-150520084715937-oozie-pi-W@:start:] with user-retry state : userRetryCount [0], userRetryMax [0], userRetryInterval [10]
2015-05-20 08:50:42,954  INFO ActionStartXCommand:541 - SERVER[TestPi2] USER[pi] GROUP[-] TOKEN[] APP[pig-app-hue-script] JOB[0000000-150520084715937-oozie-pi-W] ACTION[0000000-150520084715937-oozie-pi-W@:start:] [***0000000-150520084715937-oozie-pi-W@:start:***]Action status=DONE
2015-05-20 08:50:42,956  INFO ActionStartXCommand:541 - SERVER[TestPi2] USER[pi] GROUP[-] TOKEN[] APP[pig-app-hue-script] JOB[0000000-150520084715937-oozie-pi-W] ACTION[0000000-150520084715937-oozie-pi-W@:start:] [***0000000-150520084715937-oozie-pi-W@:start:***]Action updated in DB!
2015-05-20 08:50:44,294  INFO ActionStartXCommand:541 - SERVER[TestPi2] USER[pi] GROUP[-] TOKEN[] APP[pig-app-hue-script] JOB[0000000-150520084715937-oozie-pi-W] ACTION[0000000-150520084715937-oozie-pi-W@pig] Start action [0000000-150520084715937-oozie-pi-W@pig] with user-retry state : userRetryCount [0], userRetryMax [0], userRetryInterval [10]
2015-05-20 08:51:00,635  INFO PigActionExecutor:541 - SERVER[TestPi2] USER[pi] GROUP[-] TOKEN[] APP[pig-app-hue-script] JOB[0000000-150520084715937-oozie-pi-W] ACTION[0000000-150520084715937-oozie-pi-W@pig] checking action, hadoop job ID [job_1432059624879_0010] status [RUNNING]
2015-05-20 08:51:00,655  INFO ActionStartXCommand:541 - SERVER[TestPi2] USER[pi] GROUP[-] TOKEN[] APP[pig-app-hue-script] JOB[0000000-150520084715937-oozie-pi-W] ACTION[0000000-150520084715937-oozie-pi-W@pig] [***0000000-150520084715937-oozie-pi-W@pig***]Action status=RUNNING
2015-05-20 08:51:00,656  INFO ActionStartXCommand:541 - SERVER[TestPi2] USER[pi] GROUP[-] TOKEN[] APP[pig-app-hue-script] JOB[0000000-150520084715937-oozie-pi-W] ACTION[0000000-150520084715937-oozie-pi-W@pig] [***0000000-150520084715937-oozie-pi-W@pig***]Action updated in DB!
2015-05-20 08:52:14,380  INFO CallbackServlet:541 - SERVER[TestPi2] USER[-] GROUP[-] TOKEN[-] APP[-] JOB[0000000-150520084715937-oozie-pi-W] ACTION[0000000-150520084715937-oozie-pi-W@pig] callback for action [0000000-150520084715937-oozie-pi-W@pig]
2015-05-20 08:52:16,332  INFO PigActionExecutor:541 - SERVER[TestPi2] USER[pi] GROUP[-] TOKEN[] APP[pig-app-hue-script] JOB[0000000-150520084715937-oozie-pi-W] ACTION[0000000-150520084715937-oozie-pi-W@pig] action completed, external ID [job_1432059624879_0010]
2015-05-20 08:52:17,106  WARN PigActionExecutor:544 - SERVER[TestPi2] USER[pi] GROUP[-] TOKEN[] APP[pig-app-hue-script] JOB[0000000-150520084715937-oozie-pi-W] ACTION[0000000-150520084715937-oozie-pi-W@pig] Launcher ERROR, reason: Main class [org.apache.oozie.action.hadoop.PigMain], exit code [2]
2015-05-20 08:52:17,660  INFO ActionEndXCommand:541 - SERVER[TestPi2] USER[pi] GROUP[-] TOKEN[] APP[pig-app-hue-script] JOB[0000000-150520084715937-oozie-pi-W] ACTION[0000000-150520084715937-oozie-pi-W@pig] ERROR is considered as FAILED for SLA
2015-05-20 08:52:17,967  INFO ActionStartXCommand:541 - SERVER[TestPi2] USER[pi] GROUP[-] TOKEN[] APP[pig-app-hue-script] JOB[0000000-150520084715937-oozie-pi-W] ACTION[0000000-150520084715937-oozie-pi-W@kill] Start action [0000000-150520084715937-oozie-pi-W@kill] with user-retry state : userRetryCount [0], userRetryMax [0], userRetryInterval [10]
2015-05-20 08:52:17,968  INFO ActionStartXCommand:541 - SERVER[TestPi2] USER[pi] GROUP[-] TOKEN[] APP[pig-app-hue-script] JOB[0000000-150520084715937-oozie-pi-W] ACTION[0000000-150520084715937-oozie-pi-W@kill] [***0000000-150520084715937-oozie-pi-W@kill***]Action status=DONE
2015-05-20 08:52:17,970  INFO ActionStartXCommand:541 - SERVER[TestPi2] USER[pi] GROUP[-] TOKEN[] APP[pig-app-hue-script] JOB[0000000-150520084715937-oozie-pi-W] ACTION[0000000-150520084715937-oozie-pi-W@kill] [***0000000-150520084715937-oozie-pi-W@kill***]Action updated in DB!
15 REPLIES 15

When you open the workflow, could you click on the Log icon of the Pig
action? It should give you better logs

Romain

Explorer

my log aggregation is disabled so i had to pull these from hadoop log directory:

stderr

Pig logfile dump:

Pig Stack Trace
---------------
ERROR 1070: Could not resolve org.apache.pig.piggybank.evaluation.string.UPPER using imports: [, java.lang., org.apache.pig.builtin., org.apache.pig.impl.builtin.]

org.apache.pig.impl.logicalLayer.FrontendException: ERROR 1000: Error during parsing. Could not resolve org.apache.pig.piggybank.evaluation.string.UPPER using imports: [, java.lang., org.a$
        at org.apache.pig.PigServer$Graph.parseQuery(PigServer.java:1689)
        at org.apache.pig.PigServer$Graph.access$000(PigServer.java:1409)
        at org.apache.pig.PigServer.parseAndBuild(PigServer.java:342)
        at org.apache.pig.PigServer.executeBatch(PigServer.java:367)
        at org.apache.pig.PigServer.executeBatch(PigServer.java:353)
        at org.apache.pig.tools.grunt.GruntParser.executeBatch(GruntParser.java:140)
        at org.apache.pig.tools.grunt.GruntParser.parseStopOnError(GruntParser.java:202)
        at org.apache.pig.tools.grunt.GruntParser.parseStopOnError(GruntParser.java:173)
        at org.apache.pig.tools.grunt.Grunt.exec(Grunt.java:84)
        at org.apache.pig.Main.run(Main.java:478)
        at org.apache.pig.PigRunner.run(PigRunner.java:49)
        at org.apache.oozie.action.hadoop.PigMain.runPigJob(PigMain.java:287)
        at org.apache.oozie.action.hadoop.PigMain.run(PigMain.java:227)
        at org.apache.oozie.action.hadoop.LauncherMain.run(LauncherMain.java:39)
        at org.apache.oozie.action.hadoop.PigMain.main(PigMain.java:75)
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at java.lang.reflect.Method.invoke(Method.java:483)
        at org.apache.oozie.action.hadoop.LauncherMapper.map(LauncherMapper.java:226)
        at org.apache.hadoop.mapred.MapRunner.run(MapRunner.java:54)
        at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:450)
        at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
        at org.apache.hadoop.mapred.YarnChild$2.run(YarnChild.java:163)
        at java.security.AccessController.doPrivileged(Native Method)
        at javax.security.auth.Subject.doAs(Subject.java:422)
        at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1628)
        at org.apache.hadoop.mapred.YarnChild.main(YarnChild.java:158)
Caused by: Failed to parse: Pig script failed to parse:
<file script.pig, line 4, column 35> Failed to generate logical plan. Nested exception: org.apache.pig.backend.executionengine.ExecException: ERROR 1070: Could not resolve org.apache.pig.p$
        at org.apache.pig.parser.QueryParserDriver.parse(QueryParserDriver.java:196)
        at org.apache.pig.PigServer$Graph.parseQuery(PigServer.java:1676)
        ... 27 more
Caused by:
<file script.pig, line 4, column 35> Failed to generate logical plan. Nested exception: org.apache.pig.backend.executionengine.ExecException: ERROR 1070: Could not resolve org.apache.pig.p$
        at org.apache.pig.parser.LogicalPlanBuilder.buildUDF(LogicalPlanBuilder.java:1494)
        at org.apache.pig.parser.LogicalPlanGenerator.func_eval(LogicalPlanGenerator.java:9288)
        at org.apache.pig.parser.LogicalPlanGenerator.projectable_expr(LogicalPlanGenerator.java:10967)
        at org.apache.pig.parser.LogicalPlanGenerator.var_expr(LogicalPlanGenerator.java:10726)
        at org.apache.pig.parser.LogicalPlanGenerator.expr(LogicalPlanGenerator.java:10075)
        at org.apache.pig.parser.LogicalPlanGenerator.flatten_generated_item(LogicalPlanGenerator.java:7404)
        at org.apache.pig.parser.LogicalPlanGenerator.generate_clause(LogicalPlanGenerator.java:17506)
        at org.apache.pig.parser.LogicalPlanGenerator.foreach_plan(LogicalPlanGenerator.java:15898)
        at org.apache.pig.parser.LogicalPlanGenerator.foreach_clause(LogicalPlanGenerator.java:15765)
        at org.apache.pig.parser.LogicalPlanGenerator.op_clause(LogicalPlanGenerator.java:1844)
        at org.apache.pig.parser.LogicalPlanGenerator.general_statement(LogicalPlanGenerator.java:1013)
        at org.apache.pig.parser.LogicalPlanGenerator.statement(LogicalPlanGenerator.java:553)
        at org.apache.pig.parser.LogicalPlanGenerator.query(LogicalPlanGenerator.java:421)
        at org.apache.pig.parser.QueryParserDriver.parse(QueryParserDriver.java:188)
        ... 28 more
Caused by: org.apache.pig.backend.executionengine.ExecException: ERROR 1070: Could not resolve org.apache.pig.piggybank.evaluation.string.UPPER using imports: [, java.lang., org.apache.pig$
        at org.apache.pig.impl.PigContext.resolveClassName(PigContext.java:653)
        at org.apache.pig.impl.PigContext.getClassForAlias(PigContext.java:769)
        at org.apache.pig.parser.LogicalPlanBuilder.buildUDF(LogicalPlanBuilder.java:1491)
        ... 41 more
================================================================================
Failing Oozie Launcher, Main class [org.apache.oozie.action.hadoop.PigMain], exit code [2]

Explorer

stdout:

2015-05-21 08:52:01,127 [main] ERROR org.apache.pig.tools.grunt.Grunt  - ERROR 1070: Could not resolve org.apache.pig.piggybank.evaluation.string.UPPER using imports: [, java.lang., org.ap$

<<< Invocation of Main class completed <<<

Failing Oozie Launcher, Main class [org.apache.oozie.action.hadoop.PigMain], exit code [2]

Oozie Launcher failed, finishing Hadoop job gracefully

Explorer

sysout:

2015-05-21 08:51:44,157 INFO [main] org.apache.hadoop.metrics2.impl.MetricsConfig: loaded properties from hadoop-metrics2.properties
2015-05-21 08:51:44,648 INFO [main] org.apache.hadoop.metrics2.impl.MetricsSystemImpl: Scheduled snapshot period at 10 second(s).
2015-05-21 08:51:44,649 INFO [main] org.apache.hadoop.metrics2.impl.MetricsSystemImpl: MapTask metrics system started
2015-05-21 08:51:44,724 INFO [main] org.apache.hadoop.mapred.YarnChild: Executing with tokens:
2015-05-21 08:51:44,725 INFO [main] org.apache.hadoop.mapred.YarnChild: Kind: mapreduce.job, Service: job_1432194394555_0003, Ident: (org.apache.hadoop.mapreduce.security.token.JobTokenIde$
2015-05-21 08:51:45,137 INFO [main] org.apache.hadoop.mapred.YarnChild: Kind: RM_DELEGATION_TOKEN, Service: 192.168.0.26:8032, Ident: (owner=pi, renewer=oozie mr token, realUser=pi, issueD$
2015-05-21 08:51:45,524 INFO [main] org.apache.hadoop.mapred.YarnChild: Sleeping for 0ms before retrying again. Got null now.
2015-05-21 08:51:47,400 INFO [main] org.apache.hadoop.mapred.YarnChild: mapreduce.cluster.local.dir for child: /home/pi/hdfs/tmp/nm-local-dir/usercache/pi/appcache/application_143219439455$
2015-05-21 08:51:48,839 INFO [main] org.apache.hadoop.conf.Configuration.deprecation: session.id is deprecated. Instead, use dfs.metrics.session-id
2015-05-21 08:51:52,426 INFO [main] org.apache.hadoop.mapred.Task:  Using ResourceCalculatorProcessTree : [ ]
2015-05-21 08:51:52,512 WARN [main] org.apache.hadoop.yarn.util.ProcfsBasedProcessTree: Unexpected: procfs stat file is not in the expected format for process with pid 49
2015-05-21 08:51:53,587 INFO [main] org.apache.hadoop.mapred.MapTask: Processing split: org.apache.oozie.action.hadoop.OozieLauncherInputFormat$EmptySplit@1ce136b
2015-05-21 08:51:53,637 INFO [main] org.apache.hadoop.mapred.MapTask: numReduceTasks: 0
2015-05-21 08:51:53,904 INFO [main] org.apache.hadoop.conf.Configuration.deprecation: mapred.job.id is deprecated. Instead, use mapreduce.job.id
2015-05-21 08:51:55,455 INFO [main] org.apache.hadoop.conf.Configuration.deprecation: user.name is deprecated. Instead, use mapreduce.job.user.name

Explorer

ok, i got rid of these errors by replacing

org.apache.pig.piggybank.evaluation.string.UPPER

with just UPPER(text) in the Pig example.

 

it seems to find the right class now but what happens is that after 50 minutes, it is still running the script. It launched the first job which is stuck at 95% and then initiated a second job which is name PIGLatin:script.pig and it is stuck at 0% after 50 minutes.

 

All i see in the error logs is heartbeats. No errors in stderr and stdout. 

I replaced the initial example input with a smaller file that contains just a sentence so it is definitely not the large size of the file causing this.

It is taking 900MB of RAM and the CPU is more or less idle, so it doesn't look like it is working on anything.

 

Job Browser shows the task as running for 1 hr. Workflow shows the task running for 7 minutes with 50% progress. It has really been running for an hour.

 

When i try to click on the job in Job Browser, it tells me that there is no nodemanager running or container is not found. nodemanager is running. i think there is a problem between hadoop and oozie synchronising their containers. I have not done any configuration on the containers. Perhaps, this is the problem?

Explorer

Apologies for the quick succession of replies. I have been playing with configurations and made some progress.

 

When i submit the pig script, in the job browser i see one active task: oozie:launcher:T=pig:W:pig-app-hue-script:A=pig:ID=0000-150521.....oozie-pi-W
 
This task gets stuck at 95% and then spawns a new task which gets stuck at "Accepted":PigLatin:script.pig
 
At this point I get only heartbeats in the logs along with a message about org.apache.hadoop.yarn.util.ProcfsBasedProcessTree -Unexpected:procfs stat file is not in the expected format for process with pid 49.
 
Sometimes if I kill the tasks manually, I still end up with the output file in the HDFS path. 
 
Any ideas what might this be?

Are you on a single machine?

Usually you need to configure yarn to have each container ask for less
resources, it kind of deadlock when 1 or 2 jobs are running

Explorer

It is indeed running all on one machine. 

 

I left it for a couple of hours running both jobs until eventually it gave me this in the log:

2015-05-21 19:33:26,864  WARN PigActionExecutor:544 - SERVER[TestPi2] USER[pi] GROUP[-] TOKEN[] APP[pig-app-hue-script] JOB[0000000-150521182907165-oozie-pi-W] ACTION[0000000-150521182907165-oozie-pi-W@pig] Exception in check(). Message[java.io.IOException: Failed on local exception: java.io.EOFException; Host Details : local host is: "TestPi2/192.168.0.26"; destination host is: "TestPi2":10020; ]
java.io.IOException: java.io.IOException: Failed on local exception: java.io.EOFException; Host Details : local host is: "TestPi2/192.168.0.26"; destination host is: "TestPi2":10020; 
	at org.apache.hadoop.mapred.ClientServiceDelegate.invoke(ClientServiceDelegate.java:334)
	at org.apache.hadoop.mapred.ClientServiceDelegate.getJobStatus(ClientServiceDelegate.java:419)
	at org.apache.hadoop.mapred.YARNRunner.getJobStatus(YARNRunner.java:524)
	at org.apache.hadoop.mapreduce.Cluster.getJob(Cluster.java:183)
	at org.apache.hadoop.mapred.JobClient$2.run(JobClient.java:580)
	at org.apache.hadoop.mapred.JobClient$2.run(JobClient.java:578)
	at java.security.AccessController.doPrivileged(Native Method)
	at javax.security.auth.Subject.doAs(Subject.java:422)
	at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1548)
	at org.apache.hadoop.mapred.JobClient.getJobUsingCluster(JobClient.java:578)
	at org.apache.hadoop.mapred.JobClient.getJob(JobClient.java:596)
	at org.apache.oozie.action.hadoop.JavaActionExecutor.getRunningJob(JavaActionExecutor.java:1181)
	at org.apache.oozie.action.hadoop.JavaActionExecutor.check(JavaActionExecutor.java:1196)
	at org.apache.oozie.command.wf.ActionCheckXCommand.execute(ActionCheckXCommand.java:181)
	at org.apache.oozie.command.wf.ActionCheckXCommand.execute(ActionCheckXCommand.java:55)
	at org.apache.oozie.command.XCommand.call(XCommand.java:281)
	at org.apache.oozie.service.CallableQueueService$CallableWrapper.run(CallableQueueService.java:174)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:744)
Caused by: java.io.IOException: Failed on local exception: java.io.EOFException; Host Details : local host is: "TestPi2/192.168.0.26"; destination host is: "TestPi2":10020; 
	at org.apache.hadoop.net.NetUtils.wrapException(NetUtils.java:764)
	at org.apache.hadoop.ipc.Client.call(Client.java:1410)
	at org.apache.hadoop.ipc.Client.call(Client.java:1359)
	at org.apache.hadoop.ipc.ProtobufRpcEngine$Invoker.invoke(ProtobufRpcEngine.java:206)
	at com.sun.proxy.$Proxy30.getJobReport(Unknown Source)
	at org.apache.hadoop.mapreduce.v2.api.impl.pb.client.MRClientProtocolPBClientImpl.getJobReport(MRClientProtocolPBClientImpl.java:133)
	at sun.reflect.GeneratedMethodAccessor38.invoke(Unknown Source)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:483)
	at org.apache.hadoop.mapred.ClientServiceDelegate.invoke(ClientServiceDelegate.java:320)
	... 19 more
Caused by: java.io.EOFException
	at java.io.DataInputStream.readInt(DataInputStream.java:392)
	at org.apache.hadoop.ipc.Client$Connection.receiveRpcResponse(Client.java:1050)
	at org.apache.hadoop.ipc.Client$Connection.run(Client.java:945)
2015-05-21 19:33:26,873  WARN ActionCheckXCommand:544 - SERVER[TestPi2] USER[pi] GROUP[-] TOKEN[] APP[pig-app-hue-script] JOB[0000000-150521182907165-oozie-pi-W] ACTION[0000000-150521182907165-oozie-pi-W@pig] Exception while executing check(). Error Code [JA009], Message[JA009: Failed on local exception: java.io.EOFException; Host Details : local host is: "TestPi2/192.168.0.26"; destination host is: "TestPi2":10020; ]
org.apache.oozie.action.ActionExecutorException: JA009: Failed on local exception: java.io.EOFException; Host Details : local host is: "TestPi2/192.168.0.26"; destination host is: "TestPi2":10020; 
	at org.apache.oozie.action.ActionExecutor.convertExceptionHelper(ActionExecutor.java:412)
	at org.apache.oozie.action.ActionExecutor.convertException(ActionExecutor.java:392)
	at org.apache.oozie.action.hadoop.JavaActionExecutor.check(JavaActionExecutor.java:1296)
	at org.apache.oozie.command.wf.ActionCheckXCommand.execute(ActionCheckXCommand.java:181)
	at org.apache.oozie.command.wf.ActionCheckXCommand.execute(ActionCheckXCommand.java:55)
	at org.apache.oozie.command.XCommand.call(XCommand.java:281)
	at org.apache.oozie.service.CallableQueueService$CallableWrapper.run(CallableQueueService.java:174)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:744)
Caused by: java.io.IOException: Failed on local exception: java.io.EOFException; Host Details : local host is: "TestPi2/192.168.0.26"; destination host is: "TestPi2":10020; 
	at org.apache.hadoop.net.NetUtils.wrapException(NetUtils.java:764)
	at org.apache.hadoop.ipc.Client.call(Client.java:1410)
	at org.apache.hadoop.ipc.Client.call(Client.java:1359)
	at org.apache.hadoop.ipc.ProtobufRpcEngine$Invoker.invoke(ProtobufRpcEngine.java:206)
	at com.sun.proxy.$Proxy30.getJobReport(Unknown Source)
	at org.apache.hadoop.mapreduce.v2.api.impl.pb.client.MRClientProtocolPBClientImpl.getJobReport(MRClientProtocolPBClientImpl.java:133)
	at sun.reflect.GeneratedMethodAccessor38.invoke(Unknown Source)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:483)
	at org.apache.hadoop.mapred.ClientServiceDelegate.invoke(ClientServiceDelegate.java:320)
	at org.apache.hadoop.mapred.ClientServiceDelegate.getJobStatus(ClientServiceDelegate.java:419)
	at org.apache.hadoop.mapred.YARNRunner.getJobStatus(YARNRunner.java:524)
	at org.apache.hadoop.mapreduce.Cluster.getJob(Cluster.java:183)
	at org.apache.hadoop.mapred.JobClient$2.run(JobClient.java:580)
	at org.apache.hadoop.mapred.JobClient$2.run(JobClient.java:578)
	at java.security.AccessController.doPrivileged(Native Method)
	at javax.security.auth.Subject.doAs(Subject.java:422)
	at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1548)
	at org.apache.hadoop.mapred.JobClient.getJobUsingCluster(JobClient.java:578)
	at org.apache.hadoop.mapred.JobClient.getJob(JobClient.java:596)
	at org.apache.oozie.action.hadoop.JavaActionExecutor.getRunningJob(JavaActionExecutor.java:1181)
	at org.apache.oozie.action.hadoop.JavaActionExecutor.check(JavaActionExecutor.java:1196)
	... 7 more
Caused by: java.io.EOFException
	at java.io.DataInputStream.readInt(DataInputStream.java:392)
	at org.apache.hadoop.ipc.Client$Connection.receiveRpcResponse(Client.java:1050)
	at org.apache.hadoop.ipc.Client$Connection.run(Client.java:945)
2015-05-21 19:33:26,879  INFO ActionCheckXCommand:541 - SERVER[TestPi2] USER[pi] GROUP[-] TOKEN[] APP[pig-app-hue-script] JOB[0000000-150521182907165-oozie-pi-W] ACTION[0000000-150521182907165-oozie-pi-W@pig] Next Retry, Attempt Number [1] in [60,000] milliseconds
2015-05-21 19:34:28,003  WARN PigActionExecutor:544 - SERVER[TestPi2] USER[pi] GROUP[-] TOKEN[] APP[pig-app-hue-script] JOB[0000000-150521182907165-oozie-pi-W] ACTION[0000000-150521182907165-oozie-pi-W@pig] Exception in check(). Message[java.io.IOException: Failed on local exception: java.io.EOFException; Host Details : local host is: "TestPi2/192.168.0.26"; destination host is: "TestPi2":10020; ]
java.io.IOException: java.io.IOException: Failed on local exception: java.io.EOFException; Host Details : local host is: "TestPi2/192.168.0.26"; destination host is: "TestPi2":10020; 
	at org.apache.hadoop.mapred.ClientServiceDelegate.invoke(ClientServiceDelegate.java:334)
	at org.apache.hadoop.mapred.ClientServiceDelegate.getJobStatus(ClientServiceDelegate.java:419)
	at org.apache.hadoop.mapred.YARNRunner.getJobStatus(YARNRunner.java:524)
	at org.apache.hadoop.mapreduce.Cluster.getJob(Cluster.java:183)
	at org.apache.hadoop.mapred.JobClient$2.run(JobClient.java:580)
	at org.apache.hadoop.mapred.JobClient$2.run(JobClient.java:578)
	at java.security.AccessController.doPrivileged(Native Method)
	at javax.security.auth.Subject.doAs(Subject.java:422)
	at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1548)
	at org.apache.hadoop.mapred.JobClient.getJobUsingCluster(JobClient.java:578)
	at org.apache.hadoop.mapred.JobClient.getJob(JobClient.java:596)
	at org.apache.oozie.action.hadoop.JavaActionExecutor.getRunningJob(JavaActionExecutor.java:1181)
	at org.apache.oozie.action.hadoop.JavaActionExecutor.check(JavaActionExecutor.java:1196)
	at org.apache.oozie.command.wf.ActionCheckXCommand.execute(ActionCheckXCommand.java:181)
	at org.apache.oozie.command.wf.ActionCheckXCommand.execute(ActionCheckXCommand.java:55)
	at org.apache.oozie.command.XCommand.call(XCommand.java:281)
	at org.apache.oozie.service.CallableQueueService$CallableWrapper.run(CallableQueueService.java:174)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:744)
Caused by: java.io.IOException: Failed on local exception: java.io.EOFException; Host Details : local host is: "TestPi2/192.168.0.26"; destination host is: "TestPi2":10020; 
	at org.apache.hadoop.net.NetUtils.wrapException(NetUtils.java:764)
	at org.apache.hadoop.ipc.Client.call(Client.java:1410)
	at org.apache.hadoop.ipc.Client.call(Client.java:1359)
	at org.apache.hadoop.ipc.ProtobufRpcEngine$Invoker.invoke(ProtobufRpcEngine.java:206)
	at com.sun.proxy.$Proxy30.getJobReport(Unknown Source)
	at org.apache.hadoop.mapreduce.v2.api.impl.pb.client.MRClientProtocolPBClientImpl.getJobReport(MRClientProtocolPBClientImpl.java:133)
	at sun.reflect.GeneratedMethodAccessor38.invoke(Unknown Source)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:483)
	at org.apache.hadoop.mapred.ClientServiceDelegate.invoke(ClientServiceDelegate.java:320)
	... 19 more
Caused by: java.io.EOFException
	at java.io.DataInputStream.readInt(DataInputStream.java:392)
	at org.apache.hadoop.ipc.Client$Connection.receiveRpcResponse(Client.java:1050)
	at org.apache.hadoop.ipc.Client$Connection.run(Client.java:945)
2015-05-21 19:34:28,007  WARN ActionCheckXCommand:544 - SERVER[TestPi2] USER[pi] GROUP[-] TOKEN[] APP[pig-app-hue-script] JOB[0000000-150521182907165-oozie-pi-W] ACTION[0000000-150521182907165-oozie-pi-W@pig] Exception while executing check(). Error Code [JA009], Message[JA009: Failed on local exception: java.io.EOFException; Host Details : local host is: "TestPi2/192.168.0.26"; destination host is: "TestPi2":10020; ]
org.apache.oozie.action.ActionExecutorException: JA009: Failed on local exception: java.io.EOFException; Host Details : local host is: "TestPi2/192.168.0.26"; destination host is: "TestPi2":10020; 
	at org.apache.oozie.action.ActionExecutor.convertExceptionHelper(ActionExecutor.java:412)
	at org.apache.oozie.action.ActionExecutor.convertException(ActionExecutor.java:392)
	at org.apache.oozie.action.hadoop.JavaActionExecutor.check(JavaActionExecutor.java:1296)
	at org.apache.oozie.command.wf.ActionCheckXCommand.execute(ActionCheckXCommand.java:181)
	at org.apache.oozie.command.wf.ActionCheckXCommand.execute(ActionCheckXCommand.java:55)
	at org.apache.oozie.command.XCommand.call(XCommand.java:281)
	at org.apache.oozie.service.CallableQueueService$CallableWrapper.run(CallableQueueService.java:174)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:744)
Caused by: java.io.IOException: Failed on local exception: java.io.EOFException; Host Details : local host is: "TestPi2/192.168.0.26"; destination host is: "TestPi2":10020; 
	at org.apache.hadoop.net.NetUtils.wrapException(NetUtils.java:764)
	at org.apache.hadoop.ipc.Client.call(Client.java:1410)
	at org.apache.hadoop.ipc.Client.call(Client.java:1359)
	at org.apache.hadoop.ipc.ProtobufRpcEngine$Invoker.invoke(ProtobufRpcEngine.java:206)
	at com.sun.proxy.$Proxy30.getJobReport(Unknown Source)
	at org.apache.hadoop.mapreduce.v2.api.impl.pb.client.MRClientProtocolPBClientImpl.getJobReport(MRClientProtocolPBClientImpl.java:133)
	at sun.reflect.GeneratedMethodAccessor38.invoke(Unknown Source)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:483)
	at org.apache.hadoop.mapred.ClientServiceDelegate.invoke(ClientServiceDelegate.java:320)
	at org.apache.hadoop.mapred.ClientServiceDelegate.getJobStatus(ClientServiceDelegate.java:419)
	at org.apache.hadoop.mapred.YARNRunner.getJobStatus(YARNRunner.java:524)
	at org.apache.hadoop.mapreduce.Cluster.getJob(Cluster.java:183)
	at org.apache.hadoop.mapred.JobClient$2.run(JobClient.java:580)
	at org.apache.hadoop.mapred.JobClient$2.run(JobClient.java:578)
	at java.security.AccessController.doPrivileged(Native Method)
	at javax.security.auth.Subject.doAs(Subject.java:422)
	at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1548)
	at org.apache.hadoop.mapred.JobClient.getJobUsingCluster(JobClient.java:578)
	at org.apache.hadoop.mapred.JobClient.getJob(JobClient.java:596)
	at org.apache.oozie.action.hadoop.JavaActionExecutor.getRunningJob(JavaActionExecutor.java:1181)
	at org.apache.oozie.action.hadoop.JavaActionExecutor.check(JavaActionExecutor.java:1196)
	... 7 more
Caused by: java.io.EOFException
	at java.io.DataInputStream.readInt(DataInputStream.java:392)
	at org.apache.hadoop.ipc.Client$Connection.receiveRpcResponse(Client.java:1050)
	at org.apache.hadoop.ipc.Client$Connection.run(Client.java:945)
2015-05-21 19:34:28,012  INFO ActionCheckXCommand:541 - SERVER[TestPi2] USER[pi] GROUP[-] TOKEN[] APP[pig-app-hue-script] JOB[0000000-150521182907165-oozie-pi-W] ACTION[0000000-150521182907165-oozie-pi-W@pig] Next Retry, Attempt Number [2] in [60,000] milliseconds
2015-05-21 19:35:29,099  WARN PigActionExecutor:544 - SERVER[TestPi2] USER[pi] GROUP[-] TOKEN[] APP[pig-app-hue-script] JOB[0000000-150521182907165-oozie-pi-W] ACTION[0000000-150521182907165-oozie-pi-W@pig] Exception in check(). Message[java.io.IOException: Failed on local exception: java.io.EOFException; Host Details : local host is: "TestPi2/192.168.0.26"; destination host is: "TestPi2":10020; ]
java.io.IOException: java.io.IOException: Failed on local exception: java.io.EOFException; Host Details : local host is: "TestPi2/192.168.0.26"; destination host is: "TestPi2":10020; 
	at org.apache.hadoop.mapred.ClientServiceDelegate.invoke(ClientServiceDelegate.java:334)
	at org.apache.hadoop.mapred.ClientServiceDelegate.getJobStatus(ClientServiceDelegate.java:419)
	at org.apache.hadoop.mapred.YARNRunner.getJobStatus(YARNRunner.java:524)
	at org.apache.hadoop.mapreduce.Cluster.getJob(Cluster.java:183)
	at org.apache.hadoop.mapred.JobClient$2.run(JobClient.java:580)
	at org.apache.hadoop.mapred.JobClient$2.run(JobClient.java:578)
	at java.security.AccessController.doPrivileged(Native Method)
	at javax.security.auth.Subject.doAs(Subject.java:422)
	at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1548)
	at org.apache.hadoop.mapred.JobClient.getJobUsingCluster(JobClient.java:578)
	at org.apache.hadoop.mapred.JobClient.getJob(JobClient.java:596)
	at org.apache.oozie.action.hadoop.JavaActionExecutor.getRunningJob(JavaActionExecutor.java:1181)
	at org.apache.oozie.action.hadoop.JavaActionExecutor.check(JavaActionExecutor.java:1196)
	at org.apache.oozie.command.wf.ActionCheckXCommand.execute(ActionCheckXCommand.java:181)
	at org.apache.oozie.command.wf.ActionCheckXCommand.execute(ActionCheckXCommand.java:55)
	at org.apache.oozie.command.XCommand.call(XCommand.java:281)
	at org.apache.oozie.service.CallableQueueService$CallableWrapper.run(CallableQueueService.java:174)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:744)
Caused by: java.io.IOException: Failed on local exception: java.io.EOFException; Host Details : local host is: "TestPi2/192.168.0.26"; destination host is: "TestPi2":10020; 
	at org.apache.hadoop.net.NetUtils.wrapException(NetUtils.java:764)
	at org.apache.hadoop.ipc.Client.call(Client.java:1410)
	at org.apache.hadoop.ipc.Client.call(Client.java:1359)
	at org.apache.hadoop.ipc.ProtobufRpcEngine$Invoker.invoke(ProtobufRpcEngine.java:206)
	at com.sun.proxy.$Proxy30.getJobReport(Unknown Source)
	at org.apache.hadoop.mapreduce.v2.api.impl.pb.client.MRClientProtocolPBClientImpl.getJobReport(MRClientProtocolPBClientImpl.java:133)
	at sun.reflect.GeneratedMethodAccessor38.invoke(Unknown Source)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:483)
	at org.apache.hadoop.mapred.ClientServiceDelegate.invoke(ClientServiceDelegate.java:320)
	... 19 more
Caused by: java.io.EOFException
	at java.io.DataInputStream.readInt(DataInputStream.java:392)
	at org.apache.hadoop.ipc.Client$Connection.receiveRpcResponse(Client.java:1050)
	at org.apache.hadoop.ipc.Client$Connection.run(Client.java:945)
2015-05-21 19:35:29,105  WARN ActionCheckXCommand:544 - SERVER[TestPi2] USER[pi] GROUP[-] TOKEN[] APP[pig-app-hue-script] JOB[0000000-150521182907165-oozie-pi-W] ACTION[0000000-150521182907165-oozie-pi-W@pig] Exception while executing check(). Error Code [JA009], Message[JA009: Failed on local exception: java.io.EOFException; Host Details : local host is: "TestPi2/192.168.0.26"; destination host is: "TestPi2":10020; ]
org.apache.oozie.action.ActionExecutorException: JA009: Failed on local exception: java.io.EOFException; Host Details : local host is: "TestPi2/192.168.0.26"; destination host is: "TestPi2":10020; 
	at org.apache.oozie.action.ActionExecutor.convertExceptionHelper(ActionExecutor.java:412)
	at org.apache.oozie.action.ActionExecutor.convertException(ActionExecutor.java:392)
	at org.apache.oozie.action.hadoop.JavaActionExecutor.check(JavaActionExecutor.java:1296)
	at org.apache.oozie.command.wf.ActionCheckXCommand.execute(ActionCheckXCommand.java:181)
	at org.apache.oozie.command.wf.ActionCheckXCommand.execute(ActionCheckXCommand.java:55)
	at org.apache.oozie.command.XCommand.call(XCommand.java:281)
	at org.apache.oozie.service.CallableQueueService$CallableWrapper.run(CallableQueueService.java:174)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:744)
Caused by: java.io.IOException: Failed on local exception: java.io.EOFException; Host Details : local host is: "TestPi2/192.168.0.26"; destination host is: "TestPi2":10020; 
	at org.apache.hadoop.net.NetUtils.wrapException(NetUtils.java:764)
	at org.apache.hadoop.ipc.Client.call(Client.java:1410)
	at org.apache.hadoop.ipc.Client.call(Client.java:1359)
	at org.apache.hadoop.ipc.ProtobufRpcEngine$Invoker.invoke(ProtobufRpcEngine.java:206)
	at com.sun.proxy.$Proxy30.getJobReport(Unknown Source)
	at org.apache.hadoop.mapreduce.v2.api.impl.pb.client.MRClientProtocolPBClientImpl.getJobReport(MRClientProtocolPBClientImpl.java:133)
	at sun.reflect.GeneratedMethodAccessor38.invoke(Unknown Source)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:483)
	at org.apache.hadoop.mapred.ClientServiceDelegate.invoke(ClientServiceDelegate.java:320)
	at org.apache.hadoop.mapred.ClientServiceDelegate.getJobStatus(ClientServiceDelegate.java:419)
	at org.apache.hadoop.mapred.YARNRunner.getJobStatus(YARNRunner.java:524)
	at org.apache.hadoop.mapreduce.Cluster.getJob(Cluster.java:183)
	at org.apache.hadoop.mapred.JobClient$2.run(JobClient.java:580)
	at org.apache.hadoop.mapred.JobClient$2.run(JobClient.java:578)
	at java.security.AccessController.doPrivileged(Native Method)
	at javax.security.auth.Subject.doAs(Subject.java:422)
	at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1548)
	at org.apache.hadoop.mapred.JobClient.getJobUsingCluster(JobClient.java:578)
	at org.apache.hadoop.mapred.JobClient.getJob(JobClient.java:596)
	at org.apache.oozie.action.hadoop.JavaActionExecutor.getRunningJob(JavaActionExecutor.java:1181)
	at org.apache.oozie.action.hadoop.JavaActionExecutor.check(JavaActionExecutor.java:1196)
	... 7 more
Caused by: java.io.EOFException
	at java.io.DataInputStream.readInt(DataInputStream.java:392)
	at org.apache.hadoop.ipc.Client$Connection.receiveRpcResponse(Client.java:1050)
	at org.apache.hadoop.ipc.Client$Connection.run(Client.java:945)
2015-05-21 19:35:29,109  INFO ActionCheckXCommand:541 - SERVER[TestPi2] USER[pi] GROUP[-] TOKEN[] APP[pig-app-hue-script] JOB[0000000-150521182907165-oozie-pi-W] ACTION[0000000-150521182907165-oozie-pi-W@pig] Next Retry, Attempt Number [3] in [60,000] milliseconds
2015-05-21 19:36:30,199  WARN PigActionExecutor:544 - SERVER[TestPi2] USER[pi] GROUP[-] TOKEN[] APP[pig-app-hue-script] JOB[0000000-150521182907165-oozie-pi-W] ACTION[0000000-150521182907165-oozie-pi-W@pig] Exception in check(). Message[java.io.IOException: Failed on local exception: java.io.EOFException; Host Details : local host is: "TestPi2/192.168.0.26"; destination host is: "TestPi2":10020; ]
java.io.IOException: java.io.IOException: Failed on local exception: java.io.EOFException; Host Details : local host is: "TestPi2/192.168.0.26"; destination host is: "TestPi2":10020; 
	at org.apache.hadoop.mapred.ClientServiceDelegate.invoke(ClientServiceDelegate.java:334)
	at org.apache.hadoop.mapred.ClientServiceDelegate.getJobStatus(ClientServiceDelegate.java:419)
	at org.apache.hadoop.mapred.YARNRunner.getJobStatus(YARNRunner.java:524)
	at org.apache.hadoop.mapreduce.Cluster.getJob(Cluster.java:183)
	at org.apache.hadoop.mapred.JobClient$2.run(JobClient.java:580)
	at org.apache.hadoop.mapred.JobClient$2.run(JobClient.java:578)
	at java.security.AccessController.doPrivileged(Native Method)
	at javax.security.auth.Subject.doAs(Subject.java:422)
	at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1548)
	at org.apache.hadoop.mapred.JobClient.getJobUsingCluster(JobClient.java:578)
	at org.apache.hadoop.mapred.JobClient.getJob(JobClient.java:596)
	at org.apache.oozie.action.hadoop.JavaActionExecutor.getRunningJob(JavaActionExecutor.java:1181)
	at org.apache.oozie.action.hadoop.JavaActionExecutor.check(JavaActionExecutor.java:1196)
	at org.apache.oozie.command.wf.ActionCheckXCommand.execute(ActionCheckXCommand.java:181)
	at org.apache.oozie.command.wf.ActionCheckXCommand.execute(ActionCheckXCommand.java:55)
	at org.apache.oozie.command.XCommand.call(XCommand.java:281)
	at org.apache.oozie.service.CallableQueueService$CallableWrapper.run(CallableQueueService.java:174)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:744)
Caused by: java.io.IOException: Failed on local exception: java.io.EOFException; Host Details : local host is: "TestPi2/192.168.0.26"; destination host is: "TestPi2":10020; 
	at org.apache.hadoop.net.NetUtils.wrapException(NetUtils.java:764)
	at org.apache.hadoop.ipc.Client.call(Client.java:1410)
	at org.apache.hadoop.ipc.Client.call(Client.java:1359)
	at org.apache.hadoop.ipc.ProtobufRpcEngine$Invoker.invoke(ProtobufRpcEngine.java:206)
	at com.sun.proxy.$Proxy30.getJobReport(Unknown Source)
	at org.apache.hadoop.mapreduce.v2.api.impl.pb.client.MRClientProtocolPBClientImpl.getJobReport(MRClientProtocolPBClientImpl.java:133)
	at sun.reflect.GeneratedMethodAccessor38.invoke(Unknown Source)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:483)
	at org.apache.hadoop.mapred.ClientServiceDelegate.invoke(ClientServiceDelegate.java:320)
	... 19 more
Caused by: java.io.EOFException
	at java.io.DataInputStream.readInt(DataInputStream.java:392)
	at org.apache.hadoop.ipc.Client$Connection.receiveRpcResponse(Client.java:1050)
	at org.apache.hadoop.ipc.Client$Connection.run(Client.java:945)
2015-05-21 19:36:30,205  WARN ActionCheckXCommand:544 - SERVER[TestPi2] USER[pi] GROUP[-] TOKEN[] APP[pig-app-hue-script] JOB[0000000-150521182907165-oozie-pi-W] ACTION[0000000-150521182907165-oozie-pi-W@pig] Exception while executing check(). Error Code [JA009], Message[JA009: Failed on local exception: java.io.EOFException; Host Details : local host is: "TestPi2/192.168.0.26"; destination host is: "TestPi2":10020; ]
org.apache.oozie.action.ActionExecutorException: JA009: Failed on local exception: java.io.EOFException; Host Details : local host is: "TestPi2/192.168.0.26"; destination host is: "TestPi2":10020; 
	at org.apache.oozie.action.ActionExecutor.convertExceptionHelper(ActionExecutor.java:412)
	at org.apache.oozie.action.ActionExecutor.convertException(ActionExecutor.java:392)
	at org.apache.oozie.action.hadoop.JavaActionExecutor.check(JavaActionExecutor.java:1296)
	at org.apache.oozie.command.wf.ActionCheckXCommand.execute(ActionCheckXCommand.java:181)
	at org.apache.oozie.command.wf.ActionCheckXCommand.execute(ActionCheckXCommand.java:55)
	at org.apache.oozie.command.XCommand.call(XCommand.java:281)
	at org.apache.oozie.service.CallableQueueService$CallableWrapper.run(CallableQueueService.java:174)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:744)
Caused by: java.io.IOException: Failed on local exception: java.io.EOFException; Host Details : local host is: "TestPi2/192.168.0.26"; destination host is: "TestPi2":10020; 
	at org.apache.hadoop.net.NetUtils.wrapException(NetUtils.java:764)
	at org.apache.hadoop.ipc.Client.call(Client.java:1410)
	at org.apache.hadoop.ipc.Client.call(Client.java:1359)
	at org.apache.hadoop.ipc.ProtobufRpcEngine$Invoker.invoke(ProtobufRpcEngine.java:206)
	at com.sun.proxy.$Proxy30.getJobReport(Unknown Source)
	at org.apache.hadoop.mapreduce.v2.api.impl.pb.client.MRClientProtocolPBClientImpl.getJobReport(MRClientProtocolPBClientImpl.java:133)
	at sun.reflect.GeneratedMethodAccessor38.invoke(Unknown Source)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:483)
	at org.apache.hadoop.mapred.ClientServiceDelegate.invoke(ClientServiceDelegate.java:320)
	at org.apache.hadoop.mapred.ClientServiceDelegate.getJobStatus(ClientServiceDelegate.java:419)
	at org.apache.hadoop.mapred.YARNRunner.getJobStatus(YARNRunner.java:524)
	at org.apache.hadoop.mapreduce.Cluster.getJob(Cluster.java:183)
	at org.apache.hadoop.mapred.JobClient$2.run(JobClient.java:580)
	at org.apache.hadoop.mapred.JobClient$2.run(JobClient.java:578)
	at java.security.AccessController.doPrivileged(Native Method)
	at javax.security.auth.Subject.doAs(Subject.java:422)
	at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1548)
	at org.apache.hadoop.mapred.JobClient.getJobUsingCluster(JobClient.java:578)
	at org.apache.hadoop.mapred.JobClient.getJob(JobClient.java:596)
	at org.apache.oozie.action.hadoop.JavaActionExecutor.getRunningJob(JavaActionExecutor.java:1181)
	at org.apache.oozie.action.hadoop.JavaActionExecutor.check(JavaActionExecutor.java:1196)
	... 7 more
Caused by: java.io.EOFException
	at java.io.DataInputStream.readInt(DataInputStream.java:392)
	at org.apache.hadoop.ipc.Client$Connection.receiveRpcResponse(Client.java:1050)
	at org.apache.hadoop.ipc.Client$Connection.run(Client.java:945)
2015-05-21 19:36:30,212  WARN ActionCheckXCommand:544 - SERVER[TestPi2] USER[pi] GROUP[-] TOKEN[] APP[pig-app-hue-script] JOB[0000000-150521182907165-oozie-pi-W] ACTION[0000000-150521182907165-oozie-pi-W@pig] Exceeded max retry count [3]. Suspending Job
2015-05-21 19:36:30,216  WARN ActionCheckXCommand:544 - SERVER[TestPi2] USER[pi] GROUP[-] TOKEN[] APP[pig-app-hue-script] JOB[0000000-150521182907165-oozie-pi-W] ACTION[0000000-150521182907165-oozie-pi-W@pig] Suspending Workflow Job id=0000000-150521182907165-oozie-pi-W

 

Explorer

Could you please tell me how I can do this with yarn?

 

The only things I have at the moment are in mapred-site.xml

 

<property>
<name>mapreduce.tasktracker.map.tasks.maximum</name>
<value>2</value>
</property>

 

<property>
<name>mapreduce.tasktracker.reduce.tasks.maximum</name>
<value>2</value>
</property>

 

In yarn-site.xml

<property>

<name>yarn.scheduler.maximum-allocation-mb</name>
<value>64</value>
</property>

<property>
<name>yarn.scheduler.maximum-allocation-vcores</name>
<value>2</value>
</property>

 

I have been wanting to limit the amout of resources that hadoop uses because it is running on a Raspberry Pi. Yes, I know... But if i can get it working at this basic level, I am planning on building a Hadoop cluster with many Pi and with proper servers for teaching and university research.