Guest User

Untitled

a guest
Jun 2nd, 2016
441
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 15.09 KB | None | 0 0
  1. 2016-06-01 10:59:04,678 DEBUG (DataLoadQueueConsumerTask.java[commitUpserts]:305) => 2500 records loaded in 1 batch(es)!
  2. 2016-06-01 10:59:04,678 DEBUG (DataLoadQueueConsumerTask.java[commitUpserts]:315) => Commit took 0.468 seconds.
  3. 2016-06-01 10:59:04,692 DEBUG (DataLoadQueueConsumerTask.java[commitUpserts]:305) => 2500 records loaded in 1 batch(es)!
  4. 2016-06-01 10:59:04,692 DEBUG (DataLoadQueueConsumerTask.java[commitUpserts]:315) => Commit took 0.343 seconds.
  5. 2016-06-01 10:59:04,706 DEBUG (SLF4JLogger.java[debug]:56) => Closing connection connectionId{localValue:7080}
  6. 2016-06-01 10:59:04,881 DEBUG (DataLoadQueueConsumerTask.java[commitUpserts]:305) => 2500 records loaded in 1 batch(es)!
  7. 2016-06-01 10:59:04,881 DEBUG (DataLoadQueueConsumerTask.java[commitUpserts]:315) => Commit took 0.415 seconds.
  8. 2016-06-01 10:59:05,273 DEBUG (DataLoadQueueConsumerTask.java[commitUpserts]:305) => 2500 records loaded in 1 batch(es)!
  9. 2016-06-01 10:59:05,273 DEBUG (DataLoadQueueConsumerTask.java[commitUpserts]:315) => Commit took 0.346 seconds.
  10. 2016-06-01 10:59:05,497 DEBUG (DataLoadQueueConsumerTask.java[commitUpserts]:305) => 2500 records loaded in 1 batch(es)!
  11. 2016-06-01 10:59:05,497 DEBUG (DataLoadQueueConsumerTask.java[commitUpserts]:315) => Commit took 0.458 seconds.
  12. 2016-06-01 10:59:05,655 DEBUG (DataLoadQueueConsumerTask.java[commitUpserts]:305) => 2500 records loaded in 1 batch(es)!
  13. 2016-06-01 10:59:05,655 DEBUG (DataLoadQueueConsumerTask.java[commitUpserts]:315) => Commit took 0.458 seconds.
  14. 2016-06-01 10:59:06,008 DEBUG (DataLoadQueueConsumerTask.java[commitUpserts]:305) => 2500 records loaded in 1 batch(es)!
  15. 2016-06-01 10:59:06,008 DEBUG (DataLoadQueueConsumerTask.java[commitUpserts]:305) => 2500 records loaded in 1 batch(es)!
  16. 2016-06-01 10:59:06,008 DEBUG (DataLoadQueueConsumerTask.java[commitUpserts]:315) => Commit took 0.575 seconds.
  17. 2016-06-01 10:59:06,008 DEBUG (DataLoadQueueConsumerTask.java[commitUpserts]:315) => Commit took 0.569 seconds.
  18. 2016-06-01 10:59:06,043 INFO (ConnectionManager.java[closeMasterService]:2068) => Closing master protocol: MasterService
  19. 2016-06-01 10:59:06,044 DEBUG (DataLoadQueueConsumerTask.java[commitUpserts]:305) => 2500 records loaded in 1 batch(es)!
  20. 2016-06-01 10:59:06,045 DEBUG (DataLoadQueueConsumerTask.java[commitUpserts]:315) => Commit took 0.449 seconds.
  21. 2016-06-01 10:59:06,068 WARN (AsyncProcess.java[sendMultiAction]:985) => #1, the task was rejected by the pool. This is unexpected. Server is server2,16020,1464699764207
  22. java.util.concurrent.RejectedExecutionException: Task java.util.concurrent.FutureTask@606dde49 rejected from java.util.concurrent.ThreadPoolExecutor@4d1cbc14[Shutting down, pool size = 3, active threads = 3, queued tasks = 0, completed tasks = 4025242]
  23. at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2048)
  24. at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:821)
  25. at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1372)
  26. at java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:110)
  27. at org.apache.hadoop.hbase.client.AsyncProcess$AsyncRequestFutureImpl.sendMultiAction(AsyncProcess.java:980)
  28. at org.apache.hadoop.hbase.client.AsyncProcess$AsyncRequestFutureImpl.groupAndSendMultiAction(AsyncProcess.java:886)
  29. at org.apache.hadoop.hbase.client.AsyncProcess$AsyncRequestFutureImpl.access$100(AsyncProcess.java:575)
  30. at org.apache.hadoop.hbase.client.AsyncProcess.submitAll(AsyncProcess.java:557)
  31. at org.apache.hadoop.hbase.client.HTable.batch(HTable.java:911)
  32. at org.apache.hadoop.hbase.client.HTable.batch(HTable.java:928)
  33. at org.apache.phoenix.execute.MutationState.commit(MutationState.java:491)
  34. at org.apache.phoenix.jdbc.PhoenixConnection$3.call(PhoenixConnection.java:482)
  35. at org.apache.phoenix.jdbc.PhoenixConnection$3.call(PhoenixConnection.java:479)
  36. at org.apache.phoenix.call.CallRunner.run(CallRunner.java:53)
  37. at org.apache.phoenix.jdbc.PhoenixConnection.commit(PhoenixConnection.java:479)
  38. at com.salviol.fropsdr.loader.tasks.DataLoadQueueConsumerTask.commitUpserts(DataLoadQueueConsumerTask.java:304)
  39. at com.salviol.fropsdr.loader.tasks.DataLoadQueueConsumerTask.call(DataLoadQueueConsumerTask.java:229)
  40. at com.salviol.fropsdr.loader.tasks.DataLoadQueueConsumerTask.call(DataLoadQueueConsumerTask.java:35)
  41. at java.util.concurrent.FutureTask.run(FutureTask.java:262)
  42. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
  43. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
  44. at java.lang.Thread.run(Thread.java:744)
  45. 2016-06-01 10:59:06,074 WARN (AsyncProcess.java[sendMultiAction]:985) => #1, the task was rejected by the pool. This is unexpected. Server is server2,16020,1464699764207
  46. java.util.concurrent.RejectedExecutionException: Task java.util.concurrent.FutureTask@5ff661ea rejected from java.util.concurrent.ThreadPoolExecutor@4d1cbc14[Shutting down, pool size = 2, active threads = 2, queued tasks = 0, completed tasks = 4025243]
  47. at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2048)
  48. at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:821)
  49. at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1372)
  50. at java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:110)
  51. at org.apache.hadoop.hbase.client.AsyncProcess$AsyncRequestFutureImpl.sendMultiAction(AsyncProcess.java:980)
  52. at org.apache.hadoop.hbase.client.AsyncProcess$AsyncRequestFutureImpl.groupAndSendMultiAction(AsyncProcess.java:886)
  53. at org.apache.hadoop.hbase.client.AsyncProcess$AsyncRequestFutureImpl.access$100(AsyncProcess.java:575)
  54. at org.apache.hadoop.hbase.client.AsyncProcess.submitAll(AsyncProcess.java:557)
  55. at org.apache.hadoop.hbase.client.HTable.batch(HTable.java:911)
  56. at org.apache.hadoop.hbase.client.HTable.batch(HTable.java:928)
  57. at org.apache.phoenix.execute.MutationState.commit(MutationState.java:491)
  58. at org.apache.phoenix.jdbc.PhoenixConnection$3.call(PhoenixConnection.java:482)
  59. at org.apache.phoenix.jdbc.PhoenixConnection$3.call(PhoenixConnection.java:479)
  60. at org.apache.phoenix.call.CallRunner.run(CallRunner.java:53)
  61. at org.apache.phoenix.jdbc.PhoenixConnection.commit(PhoenixConnection.java:479)
  62. at com.salviol.fropsdr.loader.tasks.DataLoadQueueConsumerTask.commitUpserts(DataLoadQueueConsumerTask.java:304)
  63. at com.salviol.fropsdr.loader.tasks.DataLoadQueueConsumerTask.call(DataLoadQueueConsumerTask.java:229)
  64. at com.salviol.fropsdr.loader.tasks.DataLoadQueueConsumerTask.call(DataLoadQueueConsumerTask.java:35)
  65. at java.util.concurrent.FutureTask.run(FutureTask.java:262)
  66. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
  67. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
  68. at java.lang.Thread.run(Thread.java:744)
  69. 2016-06-01 10:59:06,086 WARN (AsyncProcess.java[sendMultiAction]:985) => #1, the task was rejected by the pool. This is unexpected. Server is server1,16020,1464699764279
  70. java.util.concurrent.RejectedExecutionException: Task java.util.concurrent.FutureTask@2f5c99a3 rejected from java.util.concurrent.ThreadPoolExecutor@4d1cbc14[Shutting down, pool size = 2, active threads = 2, queued tasks = 0, completed tasks = 4025243]
  71. at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2048)
  72. at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:821)
  73. at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1372)
  74. at java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:110)
  75. at org.apache.hadoop.hbase.client.AsyncProcess$AsyncRequestFutureImpl.sendMultiAction(AsyncProcess.java:980)
  76. at org.apache.hadoop.hbase.client.AsyncProcess$AsyncRequestFutureImpl.groupAndSendMultiAction(AsyncProcess.java:886)
  77. at org.apache.hadoop.hbase.client.AsyncProcess$AsyncRequestFutureImpl.access$100(AsyncProcess.java:575)
  78. at org.apache.hadoop.hbase.client.AsyncProcess.submitAll(AsyncProcess.java:557)
  79. at org.apache.hadoop.hbase.client.HTable.batch(HTable.java:911)
  80. at org.apache.hadoop.hbase.client.HTable.batch(HTable.java:928)
  81. at org.apache.phoenix.execute.MutationState.commit(MutationState.java:491)
  82. at org.apache.phoenix.jdbc.PhoenixConnection$3.call(PhoenixConnection.java:482)
  83. at org.apache.phoenix.jdbc.PhoenixConnection$3.call(PhoenixConnection.java:479)
  84. at org.apache.phoenix.call.CallRunner.run(CallRunner.java:53)
  85. at org.apache.phoenix.jdbc.PhoenixConnection.commit(PhoenixConnection.java:479)
  86. at com.salviol.fropsdr.loader.tasks.DataLoadQueueConsumerTask.commitUpserts(DataLoadQueueConsumerTask.java:304)
  87. at com.salviol.fropsdr.loader.tasks.DataLoadQueueConsumerTask.call(DataLoadQueueConsumerTask.java:229)
  88. at com.salviol.fropsdr.loader.tasks.DataLoadQueueConsumerTask.call(DataLoadQueueConsumerTask.java:35)
  89. at java.util.concurrent.FutureTask.run(FutureTask.java:262)
  90. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
  91. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
  92. at java.lang.Thread.run(Thread.java:744)
  93. 2016-06-01 10:59:06,095 INFO (ConnectionManager.java[closeZooKeeperWatcher]:1676) => Closing zookeeper sessionid=0x1550104165000d6
  94. 2016-06-01 10:59:06,096 DEBUG (ZooKeeper.java[close]:673) => Closing session: 0x1550104165000d6
  95. 2016-06-01 10:59:06,096 DEBUG (ClientCnxn.java[close]:1306) => Closing client for session: 0x1550104165000d6
  96. 2016-06-01 10:59:06,099 DEBUG (ClientCnxn.java[readResponse]:818) => Reading reply sessionid:0x1550104165000d6, packet:: clientPath:null serverPath:null finished:false header:: 7,-11 replyHeader:: 7,8589939591,0 request:: null response:: null
  97. 2016-06-01 10:59:06,100 DEBUG (ClientCnxn.java[run]:1086) => An exception was thrown while closing send thread for session 0x1550104165000d6 : Unable to read additional data from server sessionid 0x1550104165000d6, likely server has closed socket
  98. 2016-06-01 10:59:06,100 DEBUG (ClientCnxn.java[disconnect]:1290) => Disconnecting client for session: 0x1550104165000d6
  99. 2016-06-01 10:59:06,100 INFO (ZooKeeper.java[close]:684) => Session: 0x1550104165000d6 closed
  100. 2016-06-01 10:59:06,100 INFO (ClientCnxn.java[run]:512) => EventThread shut down
  101. 2016-06-01 10:59:06,100 DEBUG (RpcClientImpl.java[close]:1105) => Stopping rpc client
  102. 2016-06-01 10:59:06,106 DEBUG (JdbcUtils.java[closeConnection]:29) => Connection successfully closed!
  103. 2016-06-01 10:59:06,114 DEBUG (JdbcUtils.java[closeConnection]:29) => Connection successfully closed!
  104. 2016-06-01 10:59:06,129 ERROR (DataLoadQueueConsumerTask.java[commitUpserts]:308) => java.sql.SQLException: java.lang.IllegalArgumentException: Connection is null or closed.
  105. java.sql.SQLException: java.lang.IllegalArgumentException: Connection is null or closed.
  106. at org.apache.phoenix.query.ConnectionQueryServicesImpl.metaDataCoprocessorExec(ConnectionQueryServicesImpl.java:1055)
  107. at org.apache.phoenix.query.ConnectionQueryServicesImpl.metaDataCoprocessorExec(ConnectionQueryServicesImpl.java:1016)
  108. at org.apache.phoenix.query.ConnectionQueryServicesImpl.getTable(ConnectionQueryServicesImpl.java:1289)
  109. at org.apache.phoenix.schema.MetaDataClient.updateCache(MetaDataClient.java:446)
  110. at org.apache.phoenix.schema.MetaDataClient.updateCache(MetaDataClient.java:389)
  111. at org.apache.phoenix.schema.MetaDataClient.updateCache(MetaDataClient.java:385)
  112. at org.apache.phoenix.execute.MutationState.validate(MutationState.java:369)
  113. at org.apache.phoenix.execute.MutationState.commit(MutationState.java:417)
  114. at org.apache.phoenix.jdbc.PhoenixConnection$3.call(PhoenixConnection.java:482)
  115. at org.apache.phoenix.jdbc.PhoenixConnection$3.call(PhoenixConnection.java:479)
  116. at org.apache.phoenix.call.CallRunner.run(CallRunner.java:53)
  117. at org.apache.phoenix.jdbc.PhoenixConnection.commit(PhoenixConnection.java:479)
  118. at com.salviol.fropsdr.loader.tasks.DataLoadQueueConsumerTask.commitUpserts(DataLoadQueueConsumerTask.java:304)
  119. at com.salviol.fropsdr.loader.tasks.DataLoadQueueConsumerTask.call(DataLoadQueueConsumerTask.java:229)
  120. at com.salviol.fropsdr.loader.tasks.DataLoadQueueConsumerTask.call(DataLoadQueueConsumerTask.java:35)
  121. at java.util.concurrent.FutureTask.run(FutureTask.java:262)
  122. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
  123. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
  124. at java.lang.Thread.run(Thread.java:744)
  125. Caused by: java.lang.IllegalArgumentException: Connection is null or closed.
  126. at org.apache.hadoop.hbase.client.HTable.<init>(HTable.java:299)
  127. at org.apache.hadoop.hbase.client.ConnectionManager$HConnectionImplementation.getTable(ConnectionManager.java:726)
  128. at org.apache.hadoop.hbase.client.ConnectionManager$HConnectionImplementation.getTable(ConnectionManager.java:708)
  129. at org.apache.hadoop.hbase.client.ConnectionManager$HConnectionImplementation.getTable(ConnectionManager.java:703)
  130. at org.apache.phoenix.query.HTableFactory$HTableFactoryImpl.getTable(HTableFactory.java:51)
  131. at org.apache.phoenix.query.ConnectionQueryServicesImpl.getTable(ConnectionQueryServicesImpl.java:309)
  132. at org.apache.phoenix.query.ConnectionQueryServicesImpl.metaDataCoprocessorExec(ConnectionQueryServicesImpl.java:1034)
  133. ... 18 more
  134. 2016-06-01 10:59:06,130 DEBUG (DataLoadQueueConsumerTask.java[commitUpserts]:315) => Commit took 0.071 seconds.
  135. 2016-06-01 10:59:06,176 ERROR (AsyncProcess.java[manageLocationError]:927) => Cannot get replica 0 location for {"totalColumns":1,"families":{"0":[{"timestamp":1464771545776,"tag":[],"qualifier":"_0","vlen":0}]},"row":"10.10.10.158\\x00971.8.99.64\\x00\\x80\\x00\\x01U\\x03\\xB2\\xBFp\\x00\\x00\\x00\\x00\\xA2\\x91\\xDA\\xDD\\x9C\\xF0\\xFD\\x93"}
  136. 2016-06-01 10:59:06,178 ERROR (AsyncProcess.java[manageLocationError]:927) => Cannot get replica 0 location for {"totalColumns":1,"families":{"0":[{"timestamp":1464771545776,"tag":[],"qualifier":"_0","vlen":0}]},"row":"10.10.10.9\\x00341.13.99.64\\x00\\x80\\x00\\x01U\\x03\\xB2\\xC7@\\x00\\x00\\x00\\x00\\xA2\\x91\\xDA\\xDD\\x9C\\xF17F"}
  137. 2016-06-01 10:59:06,179 ERROR (AsyncProcess.java[manageLocationError]:927) => Cannot get replica 0 location for {"totalColumns":1,"families":{"0":[{"timestamp":1464771545776,"tag":[],"qualifier":"_0","vlen":0}]},"row":"10.10.10.168\\x00512.011.99.64\\x00\\x80\\x00\\x01U\\x03\\xB3z\\xF0\\x00\\x00\\x00\\x00\\xA2\\x91\\xDA\\xDD\\x9C\\xF1\\x01\\xE7"}
Advertisement
Add Comment
Please, Sign In to add comment