You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@druid.apache.org by GitBox <gi...@apache.org> on 2019/04/24 07:24:23 UTC
[GitHub] [incubator-druid] jintaohuang opened a new issue #7538: Kafka
Indexing Service (Stream pull)Task Failed
jintaohuang opened a new issue #7538: Kafka Indexing Service (Stream pull)Task Failed
URL: https://github.com/apache/incubator-druid/issues/7538
hadoop version 2.7.3 druid version 0.13.0
kafka indexing service (stream pull) task Failed .The middlemanager running log is as follows：
[2019-04-23 01:47:39:002] [INFO] - org.apache.druid.java.util.common.logger.Logger.info(Logger.java:71) - Wrote task report to: /home/mpup/mpupdefault/logs/druid/indexing-logs/index_kafka_ipfix_dev_inf_flow_5d8a7ae7eb302d7_a
egcpoef.report.json
[2019-04-23 01:47:39:002] [INFO] - org.apache.druid.java.util.common.logger.Logger.info(Logger.java:71) - Task [index_kafka_ipfix_dev_inf_flow_5d8a7ae7eb302d7_aegcpoef] status changed to [FAILED].
[2019-04-23 01:47:39:003] [ERROR] - com.google.common.util.concurrent.ExecutionList.executeListener(ExecutionList.java:161) - RuntimeException while executing runnable com.google.common.util.concurrent.Futures$4@7afa2639 wit
h executor com.google.common.util.concurrent.MoreExecutors$SameThreadExecutorService@60e72ea
java.util.concurrent.RejectedExecutionException: Task org.apache.druid.indexing.worker.WorkerTaskManager$$Lambda$63/654898858@67550bbc rejected from java.util.concurrent.ThreadPoolExecutor@52617669[Terminated, pool size = 0,
active threads = 0, queued tasks = 0, completed tasks = 99]
at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2063) ~[?:1.8.0_152]
at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:830) ~[?:1.8.0_152]
at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1379) ~[?:1.8.0_152]
at java.util.concurrent.Executors$DelegatedExecutorService.execute(Executors.java:668) ~[?:1.8.0_152]
at org.apache.druid.indexing.worker.WorkerTaskManager.submitNoticeToExec(WorkerTaskManager.java:179) ~[druid-indexing-service-0.13.0-incubating.jar:0.13.0-incubating]
at org.apache.druid.indexing.worker.WorkerTaskManager.access$000(WorkerTaskManager.java:77) ~[druid-indexing-service-0.13.0-incubating.jar:0.13.0-incubating]
at org.apache.druid.indexing.worker.WorkerTaskManager$2.onSuccess(WorkerTaskManager.java:243) ~[druid-indexing-service-0.13.0-incubating.jar:0.13.0-incubating]
at org.apache.druid.indexing.worker.WorkerTaskManager$2.onSuccess(WorkerTaskManager.java:239) ~[druid-indexing-service-0.13.0-incubating.jar:0.13.0-incubating]
at com.google.common.util.concurrent.Futures$4.run(Futures.java:1181) ~[guava-16.0.1.jar:?]
at com.google.common.util.concurrent.MoreExecutors$SameThreadExecutorService.execute(MoreExecutors.java:297) ~[guava-16.0.1.jar:?]
at com.google.common.util.concurrent.ExecutionList.executeListener(ExecutionList.java:156) [guava-16.0.1.jar:?]
at com.google.common.util.concurrent.ExecutionList.execute(ExecutionList.java:145) [guava-16.0.1.jar:?]
at com.google.common.util.concurrent.ListenableFutureTask.done(ListenableFutureTask.java:91) [guava-16.0.1.jar:?]
at java.util.concurrent.FutureTask.finishCompletion(FutureTask.java:384) [?:1.8.0_152]
at java.util.concurrent.FutureTask.set(FutureTask.java:233) [?:1.8.0_152]
at java.util.concurrent.FutureTask.run(FutureTask.java:274) [?:1.8.0_152]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_152]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_152]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_152]
[2019-04-23 01:47:39:341] [INFO] - org.apache.druid.java.util.common.logger.Logger.info(Logger.java:71) - Process exited with status[2] for task: index_kafka_ipfix_dev_flow_session_506bba34e7dae46_hplblimk
[2019-04-23 01:47:39:342] [INFO] - org.apache.druid.java.util.common.logger.Logger.info(Logger.java:71) - Wrote task log to: /home/mpup/mpupdefault/logs/druid/indexing-logs/index_kafka_ipfix_dev_flow_session_506bba34e7dae46_
hplblimk.log
[2019-04-23 01:47:39:342] [INFO] - org.apache.druid.java.util.common.logger.Logger.info(Logger.java:71) - Wrote task report to: /home/mpup/mpupdefault/logs/druid/indexing-logs/index_kafka_ipfix_dev_flow_session_506bba34e7dae
46_hplblimk.report.json
[2019-04-23 01:47:39:342] [INFO] - org.apache.druid.java.util.common.logger.Logger.info(Logger.java:71) - Task [index_kafka_ipfix_dev_flow_session_506bba34e7dae46_hplblimk] status changed to [FAILED].
[2019-04-23 01:47:39:343] [ERROR] - com.google.common.util.concurrent.ExecutionList.executeListener(ExecutionList.java:161) - RuntimeException while executing runnable com.google.common.util.concurrent.Futures$4@c3efda6 with
executor com.google.common.util.concurrent.MoreExecutors$SameThreadExecutorService@d2dd5a8
java.util.concurrent.RejectedExecutionException: Task org.apache.druid.indexing.worker.WorkerTaskManager$$Lambda$63/654898858@3d09a76a rejected from java.util.concurrent.ThreadPoolExecutor@52617669[Terminated, pool size = 0,
active threads = 0, queued tasks = 0, completed tasks = 99]
at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2063) ~[?:1.8.0_152]
at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:830) ~[?:1.8.0_152]
at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1379) ~[?:1.8.0_152]
at java.util.concurrent.Executors$DelegatedExecutorService.execute(Executors.java:668) ~[?:1.8.0_152]
at org.apache.druid.indexing.worker.WorkerTaskManager.submitNoticeToExec(WorkerTaskManager.java:179) ~[druid-indexing-service-0.13.0-incubating.jar:0.13.0-incubating]
at org.apache.druid.indexing.worker.WorkerTaskManager.access$000(WorkerTaskManager.java:77) ~[druid-indexing-service-0.13.0-incubating.jar:0.13.0-incubating]
at org.apache.druid.indexing.worker.WorkerTaskManager$2.onSuccess(WorkerTaskManager.java:243) ~[druid-indexing-service-0.13.0-incubating.jar:0.13.0-incubating]
at org.apache.druid.indexing.worker.WorkerTaskManager$2.onSuccess(WorkerTaskManager.java:239) ~[druid-indexing-service-0.13.0-incubating.jar:0.13.0-incubating]
at com.google.common.util.concurrent.Futures$4.run(Futures.java:1181) ~[guava-16.0.1.jar:?]
at com.google.common.util.concurrent.MoreExecutors$SameThreadExecutorService.execute(MoreExecutors.java:297) ~[guava-16.0.1.jar:?]
at com.google.common.util.concurrent.ExecutionList.executeListener(ExecutionList.java:156) [guava-16.0.1.jar:?]
at com.google.common.util.concurrent.ExecutionList.execute(ExecutionList.java:145) [guava-16.0.1.jar:?]
at com.google.common.util.concurrent.ListenableFutureTask.done(ListenableFutureTask.java:91) [guava-16.0.1.jar:?]
at java.util.concurrent.FutureTask.finishCompletion(FutureTask.java:384) [?:1.8.0_152]
at java.util.concurrent.FutureTask.set(FutureTask.java:233) [?:1.8.0_152]
at java.util.concurrent.FutureTask.run(FutureTask.java:274) [?:1.8.0_152]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_152]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_152]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_152]
[2019-04-23 01:47:40:112] [INFO] - org.apache.druid.java.util.common.logger.Logger.info(Logger.java:71) - Process exited with status[2] for task: index_kafka_ipfix_flow_session_f1d7e2f5bfdf70f_gmmkoifn
[2019-04-23 01:47:40:113] [INFO] - org.apache.druid.java.util.common.logger.Logger.info(Logger.java:71) - Wrote task log to: /home/mpup/mpupdefault/logs/druid/indexing-logs/index_kafka_ipfix_flow_session_f1d7e2f5bfdf70f_gmmk
oifn.log
[2019-04-23 01:47:40:113] [INFO] - org.apache.druid.java.util.common.logger.Logger.info(Logger.java:71) - Wrote task report to: /home/mpup/mpupdefault/logs/druid/indexing-logs/index_kafka_ipfix_flow_session_f1d7e2f5bfdf70f_g
mmkoifn.report.json
[2019-04-23 01:47:40:114] [INFO] - org.apache.druid.java.util.common.logger.Logger.info(Logger.java:71) - Task [index_kafka_ipfix_flow_session_f1d7e2f5bfdf70f_gmmkoifn] status changed to [FAILED].
[2019-04-23 01:47:40:114] [ERROR] - com.google.common.util.concurrent.ExecutionList.executeListener(ExecutionList.java:161) - RuntimeException while executing runnable com.google.common.util.concurrent.Futures$4@4228ac40 wit
h executor com.google.common.util.concurrent.MoreExecutors$SameThreadExecutorService@51639c5
java.util.concurrent.RejectedExecutionException: Task org.apache.druid.indexing.worker.WorkerTaskManager$$Lambda$63/654898858@7b3dc766 rejected from java.util.concurrent.ThreadPoolExecutor@52617669[Terminated, pool size = 0,
active threads = 0, queued tasks = 0, completed tasks = 99]
at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2063) ~[?:1.8.0_152]
at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:830) ~[?:1.8.0_152]
at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1379) ~[?:1.8.0_152]
at java.util.concurrent.Executors$DelegatedExecutorService.execute(Executors.java:668) ~[?:1.8.0_152]
at org.apache.druid.indexing.worker.WorkerTaskManager.submitNoticeToExec(WorkerTaskManager.java:179) ~[druid-indexing-service-0.13.0-incubating.jar:0.13.0-incubating]
at org.apache.druid.indexing.worker.WorkerTaskManager.access$000(WorkerTaskManager.java:77) ~[druid-indexing-service-0.13.0-incubating.jar:0.13.0-incubating]
at org.apache.druid.indexing.worker.WorkerTaskManager$2.onSuccess(WorkerTaskManager.java:243) ~[druid-indexing-service-0.13.0-incubating.jar:0.13.0-incubating]
at org.apache.druid.indexing.worker.WorkerTaskManager$2.onSuccess(WorkerTaskManager.java:239) ~[druid-indexing-service-0.13.0-incubating.jar:0.13.0-incubating]
at com.google.common.util.concurrent.Futures$4.run(Futures.java:1181) ~[guava-16.0.1.jar:?]
at com.google.common.util.concurrent.MoreExecutors$SameThreadExecutorService.execute(MoreExecutors.java:297) ~[guava-16.0.1.jar:?]
at com.google.common.util.concurrent.ExecutionList.executeListener(ExecutionList.java:156) [guava-16.0.1.jar:?]
at com.google.common.util.concurrent.ExecutionList.execute(ExecutionList.java:145) [guava-16.0.1.jar:?]
at com.google.common.util.concurrent.ListenableFutureTask.done(ListenableFutureTask.java:91) [guava-16.0.1.jar:?]
at java.util.concurrent.FutureTask.finishCompletion(FutureTask.java:384) [?:1.8.0_152]
at java.util.concurrent.FutureTask.set(FutureTask.java:233) [?:1.8.0_152]
at java.util.concurrent.FutureTask.run(FutureTask.java:274) [?:1.8.0_152]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_152]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_152]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_152]
[2019-04-23 01:47:40:114] [INFO] - org.apache.druid.java.util.common.logger.Logger.info(Logger.java:71) - Finished stopping in 3,537ms.
[2019-04-23 01:47:40:115] [INFO] - org.apache.druid.java.util.common.logger.Logger.info(Logger.java:71) - Stopped WorkerTaskManager.
[2019-04-23 01:47:40:115] [INFO] - org.apache.druid.java.util.common.logger.Logger.info(Logger.java:71) - Stopped WorkerTaskMonitor.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
With regards,
Apache Git Services
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@druid.apache.org
For additional commands, e-mail: commits-help@druid.apache.org