EOFException - TezJob - Cannot submit DAG

[pth001 <Pa...@uni.no>]

Hi,

I ran a pig script on tez and got the EOFException. Check at 
http://wiki.apache.org/hadoop/EOFException I have no ideas at all how I 
can fix it. However I did not get the exception when I executed this pig 
script on MR.

I am using HadoopVersion: 2.6.0.2.2.4.2-2, PigVersion: 0.14.0.2.2.4.2-2, 
TezVersion: 0.5.2.2.2.4.2-2

I will appreciate any suggestions. Thanks.

2015-05-22 14:44:13,638 [PigTezLauncher-0] ERROR 
org.apache.pig.backend.hadoop.executionengine.tez.TezJob - Cannot submit 
DAG - Application id: application_1432237888868_0133
org.apache.tez.dag.api.TezException: 
com.google.protobuf.ServiceException: java.io.EOFException: End of File 
Exception between local host is: "compute-10-0.local/10.10.255.241"; 
destination host is: "compute-10-3.local":47111; : java.io.EOFException; 
For more details see: http://wiki.apache.org/hadoop/EOFException
     at 
org.apache.tez.client.TezClient.submitDAGSession(TezClient.java:415)
     at org.apache.tez.client.TezClient.submitDAG(TezClient.java:351)
     at 
org.apache.pig.backend.hadoop.executionengine.tez.TezJob.run(TezJob.java:162)
     at 
org.apache.pig.backend.hadoop.executionengine.tez.TezLauncher$1.run(TezLauncher.java:167)
     at 
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
     at java.util.concurrent.FutureTask.run(FutureTask.java:262)
     at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
     at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
     at java.lang.Thread.run(Thread.java:744)
Caused by: com.google.protobuf.ServiceException: java.io.EOFException: 
End of File Exception between local host is: 
"compute-10-0.local/10.10.255.241"; destination host is: 
"compute-10-3.local":47111; : java.io.EOFException; For more details 
see: http://wiki.apache.org/hadoop/EOFException
     at 
org.apache.hadoop.ipc.ProtobufRpcEngine$Invoker.invoke(ProtobufRpcEngine.java:246)
     at com.sun.proxy.$Proxy31.submitDAG(Unknown Source)
     at 
org.apache.tez.client.TezClient.submitDAGSession(TezClient.java:408)
     ... 8 more
Caused by: java.io.EOFException: End of File Exception between local 
host is: "compute-10-0.local/10.10.255.241"; destination host is: 
"compute-10-3.local":47111; : java.io.EOFException; For more details 
see: http://wiki.apache.org/hadoop/EOFException
     at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native 
Method)
     at 
sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57)
     at 
sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
     at java.lang.reflect.Constructor.newInstance(Constructor.java:526)
     at org.apache.hadoop.net.NetUtils.wrapWithMessage(NetUtils.java:791)
     at org.apache.hadoop.net.NetUtils.wrapException(NetUtils.java:764)
     at org.apache.hadoop.ipc.Client.call(Client.java:1473)
     at org.apache.hadoop.ipc.Client.call(Client.java:1400)
     at 
org.apache.hadoop.ipc.ProtobufRpcEngine$Invoker.invoke(ProtobufRpcEngine.java:232)
     ... 10 more
Caused by: java.io.EOFException
     at java.io.DataInputStream.readInt(DataInputStream.java:392)
     at 
org.apache.hadoop.ipc.Client$Connection.receiveRpcResponse(Client.java:1072)
     at org.apache.hadoop.ipc.Client$Connection.run(Client.java:967)