Can you check if the hadoop version on your cluster and the version of hadoop jars on your pig classpath same? Also is the tez jars on pig classpath and the tez jars installed in hdfs are of the same version?
-Rohini On Fri, May 22, 2015 at 10:26 AM, Hitesh Shah <hit...@apache.org> wrote: > 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 <patcharee.thong...@uni.no> 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) > >
