Hello Patcharee Could you start with sending a mail to users@pig to see if they have come across this issue first? Also, can you check the application master logs to see if there are any errors ( might be useful to enable DEBUG level logging to get more information )?
thanks — Hitesh On May 22, 2015, at 5:50 AM, patcharee <[email protected]> wrote: > 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)
