API tools faq
paste
Guest User

pig log

a guest
Sep 25th, 2013
24
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 8.74 KB | None | 0 0
raw download clone embed print report
  1. Backend error message during job submission
  2. -------------------------------------------
  3. org.apache.pig.backend.executionengine.ExecException: ERROR 2118: Could not get input splits
  4. at org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigInputFormat.getSplits(PigInputFormat.java:288)
  5. at org.apache.hadoop.mapred.JobClient.writeNewSplits(JobClient.java:1054)
  6. at org.apache.hadoop.mapred.JobClient.writeSplits(JobClient.java:1071)
  7. at org.apache.hadoop.mapred.JobClient.access$700(JobClient.java:179)
  8. at org.apache.hadoop.mapred.JobClient$2.run(JobClient.java:983)
  9. at org.apache.hadoop.mapred.JobClient$2.run(JobClient.java:936)
  10. at java.security.AccessController.doPrivileged(Native Method)
  11. at javax.security.auth.Subject.doAs(Subject.java:415)
  12. at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1190)
  13. at org.apache.hadoop.mapred.JobClient.submitJobInternal(JobClient.java:936)
  14. at org.apache.hadoop.mapred.JobClient.submitJob(JobClient.java:910)
  15. at org.apache.hadoop.mapred.jobcontrol.Job.submit(Job.java:378)
  16. at org.apache.hadoop.mapred.jobcontrol.JobControl.startReadyJobs(JobControl.java:247)
  17. at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  18. at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
  19. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  20. at java.lang.reflect.Method.invoke(Method.java:601)
  21. at org.apache.pig.backend.hadoop20.PigJobControl.mainLoopAction(PigJobControl.java:157)
  22. at org.apache.pig.backend.hadoop20.PigJobControl.run(PigJobControl.java:134)
  23. at java.lang.Thread.run(Thread.java:722)
  24. at org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MapReduceLauncher$1.run(MapReduceLauncher.java:257)
  25. Caused by: java.io.IOException: Could not get input splits
  26. at org.apache.cassandra.hadoop.AbstractColumnFamilyInputFormat.getSplits(AbstractColumnFamilyInputFormat.java:191)
  27. at org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigInputFormat.getSplits(PigInputFormat.java:274)
  28. ... 20 more
  29. Caused by: java.util.concurrent.ExecutionException: java.io.IOException: failed connecting to all endpoints 127.0.0.1, connections: rpc_endpoint: 127.0.0.1, listen_endpoint: 127.0.0.1, host: 127.0.0.1, port: 9160
  30. , errors: java.io.IOException: Unable to connect to server 127.0.0.1:9160
  31. at org.apache.cassandra.hadoop.ConfigHelper.createConnection(ConfigHelper.java:575)
  32. at org.apache.cassandra.hadoop.AbstractColumnFamilyInputFormat.getSubSplits(AbstractColumnFamilyInputFormat.java:278)
  33. at org.apache.cassandra.hadoop.AbstractColumnFamilyInputFormat.access$200(AbstractColumnFamilyInputFormat.java:64)
  34. at org.apache.cassandra.hadoop.AbstractColumnFamilyInputFormat$SplitCallable.call(AbstractColumnFamilyInputFormat.java:224)
  35. at org.apache.cassandra.hadoop.AbstractColumnFamilyInputFormat$SplitCallable.call(AbstractColumnFamilyInputFormat.java:209)
  36. at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:334)
  37. at java.util.concurrent.FutureTask.run(FutureTask.java:166)
  38. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
  39. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
  40. at java.lang.Thread.run(Thread.java:722)
  41. Caused by: org.apache.thrift.transport.TTransportException: java.net.SocketException: Connection reset by peer
  42. at org.apache.thrift.transport.TSocket.open(TSocket.java:183)
  43. at org.apache.thrift.transport.TFramedTransport.open(TFramedTransport.java:81)
  44. at org.apache.cassandra.thrift.TFramedTransportFactory.openTransport(TFramedTransportFactory.java:42)
  45. at org.apache.cassandra.hadoop.ConfigHelper.createConnection(ConfigHelper.java:570)
  46. ... 9 more
  47. Caused by: java.net.SocketException: Connection reset by peer
  48. at java.net.PlainSocketImpl.socketConnect(Native Method)
  49. at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:339)
  50. at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:200)
  51. at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:182)
  52. at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:391)
  53. at java.net.Socket.connect(Socket.java:579)
  54. at org.apache.thrift.transport.TSocket.open(TSocket.java:178)
  55. ... 12 more
  56.  
  57. at java.util.concurrent.FutureTask$Sync.innerGet(FutureTask.java:252)
  58. at java.util.concurrent.FutureTask.get(FutureTask.java:111)
  59. at org.apache.cassandra.hadoop.AbstractColumnFamilyInputFormat.getSplits(AbstractColumnFamilyInputFormat.java:187)
  60. ... 21 more
  61. Caused by: java.io.IOException: failed connecting to all endpoints 127.0.0.1, connections: rpc_endpoint: 127.0.0.1, listen_endpoint: 127.0.0.1, host: 127.0.0.1, port: 9160
  62. , errors: java.io.IOException: Unable to connect to server 127.0.0.1:9160
  63. at org.apache.cassandra.hadoop.ConfigHelper.createConnection(ConfigHelper.java:575)
  64. at org.apache.cassandra.hadoop.AbstractColumnFamilyInputFormat.getSubSplits(AbstractColumnFamilyInputFormat.java:278)
  65. at org.apache.cassandra.hadoop.AbstractColumnFamilyInputFormat.access$200(AbstractColumnFamilyInputFormat.java:64)
  66. at org.apache.cassandra.hadoop.AbstractColumnFamilyInputFormat$SplitCallable.call(AbstractColumnFamilyInputFormat.java:224)
  67. at org.apache.cassandra.hadoop.AbstractColumnFamilyInputFormat$SplitCallable.call(AbstractColumnFamilyInputFormat.java:209)
  68. at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:334)
  69. at java.util.concurrent.FutureTask.run(FutureTask.java:166)
  70. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
  71. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
  72. at java.lang.Thread.run(Thread.java:722)
  73. Caused by: org.apache.thrift.transport.TTransportException: java.net.SocketException: Connection reset by peer
  74. at org.apache.thrift.transport.TSocket.open(TSocket.java:183)
  75. at org.apache.thrift.transport.TFramedTransport.open(TFramedTransport.java:81)
  76. at org.apache.cassandra.thrift.TFramedTransportFactory.openTransport(TFramedTransportFactory.java:42)
  77. at org.apache.cassandra.hadoop.ConfigHelper.createConnection(ConfigHelper.java:570)
  78. ... 9 more
  79. Caused by: java.net.SocketException: Connection reset by peer
  80. at java.net.PlainSocketImpl.socketConnect(Native Method)
  81. at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:339)
  82. at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:200)
  83. at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:182)
  84. at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:391)
  85. at java.net.Socket.connect(Socket.java:579)
  86. at org.apache.thrift.transport.TSocket.open(TSocket.java:178)
  87. ... 12 more
  88.  
  89. at org.apache.cassandra.hadoop.AbstractColumnFamilyInputFormat.getSubSplits(AbstractColumnFamilyInputFormat.java:310)
  90. at org.apache.cassandra.hadoop.AbstractColumnFamilyInputFormat.access$200(AbstractColumnFamilyInputFormat.java:64)
  91. at org.apache.cassandra.hadoop.AbstractColumnFamilyInputFormat$SplitCallable.call(AbstractColumnFamilyInputFormat.java:224)
  92. at org.apache.cassandra.hadoop.AbstractColumnFamilyInputFormat$SplitCallable.call(AbstractColumnFamilyInputFormat.java:209)
  93. at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:334)
  94. at java.util.concurrent.FutureTask.run(FutureTask.java:166)
  95. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
  96. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
  97. at java.lang.Thread.run(Thread.java:722)
  98.  
  99. Pig Stack Trace
  100. ---------------
  101. ERROR 1066: Unable to open iterator for alias data
  102.  
  103. org.apache.pig.impl.logicalLayer.FrontendException: ERROR 1066: Unable to open iterator for alias data
  104. at org.apache.pig.PigServer.openIterator(PigServer.java:836)
  105. at org.apache.pig.tools.grunt.GruntParser.processDump(GruntParser.java:696)
  106. at org.apache.pig.tools.pigscript.parser.PigScriptParser.parse(PigScriptParser.java:320)
  107. at org.apache.pig.tools.grunt.GruntParser.parseStopOnError(GruntParser.java:194)
  108. at org.apache.pig.tools.grunt.GruntParser.parseStopOnError(GruntParser.java:170)
  109. at org.apache.pig.tools.grunt.Grunt.exec(Grunt.java:84)
  110. at org.apache.pig.Main.run(Main.java:604)
  111. at org.apache.pig.Main.main(Main.java:157)
  112. at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  113. at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
  114. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  115. at java.lang.reflect.Method.invoke(Method.java:601)
  116. at org.apache.hadoop.util.RunJar.main(RunJar.java:160)
  117. Caused by: java.io.IOException: Job terminated with anomalous status FAILED
  118. at org.apache.pig.PigServer.openIterator(PigServer.java:828)
  119. ... 12 more
  120. ================================================================================
Advertisement
Add Comment
Please, Sign In to add comment
Public Pastes
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!