Created
June 5, 2018 02:01
-
-
Save ChenShuai1981/b26c203d5cedfe09d5e68566ca245542 to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| 2018-06-04T10:43:48,812 INFO [forking-task-runner-5] io.druid.storage.hdfs.tasklog.HdfsTaskLogs - Writing task log to: /druid/indexing-logs/index_kafka_preprod-risk-invocation-history-kafka_39f2b2a2bddc733_bpgmpcih | |
| 2018-06-04T10:43:48,830 INFO [forking-task-runner-5] io.druid.storage.hdfs.tasklog.HdfsTaskLogs - Wrote task log to: /druid/indexing-logs/index_kafka_preprod-risk-invocation-history-kafka_39f2b2a2bddc733_bpgmpcih | |
| 2018-06-04T10:43:48,830 INFO [forking-task-runner-5] io.druid.indexing.overlord.TaskRunnerUtils - Task [index_kafka_preprod-risk-invocation-history-kafka_39f2b2a2bddc733_bpgmpcih] status changed to [SUCCESS]. | |
| 2018-06-04T10:43:48,830 INFO [forking-task-runner-5] io.druid.indexing.overlord.ForkingTaskRunner - Removing task directory: var/druid/task/index_kafka_preprod-risk-invocation-history-kafka_39f2b2a2bddc733_bpgmpcih | |
| 2018-06-04T10:43:48,833 INFO [WorkerTaskManager-NoticeHandler] io.druid.indexing.worker.WorkerTaskManager - Job's finished. Completed [index_kafka_preprod-risk-invocation-history-kafka_39f2b2a2bddc733_bpgmpcih] with status [SUCCESS] | |
| 2018-06-04T10:46:30,584 INFO [WorkerTaskManager-CompletedTasksCleaner] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8090 | |
| 2018-06-04T10:46:30,590 INFO [WorkerTaskManager-CompletedTasksCleaner] io.druid.indexing.worker.WorkerTaskManager - Deleting completed task[index_kafka_preprod-risk-invocation-history-kafka_39f2b2a2bddc733_bpgmpcih] information, overlord task status[SUCCESS]. | |
| 2018-06-04T11:43:12,227 INFO [qtp299684908-96] io.druid.indexing.overlord.ForkingTaskRunner - Killing process for task: index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ghgdghfl | |
| 2018-06-04T11:43:12,231 INFO [forking-task-runner-4] io.druid.storage.hdfs.tasklog.HdfsTaskLogs - Writing task log to: /druid/indexing-logs/index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ghgdghfl | |
| 2018-06-04T11:43:12,252 INFO [qtp299684908-88] io.druid.indexing.overlord.ForkingTaskRunner - Killing process for task: index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ghgdghfl | |
| 2018-06-04T11:43:12,266 INFO [forking-task-runner-4] io.druid.storage.hdfs.tasklog.HdfsTaskLogs - Wrote task log to: /druid/indexing-logs/index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ghgdghfl | |
| 2018-06-04T11:43:12,266 INFO [forking-task-runner-4] io.druid.indexing.overlord.ForkingTaskRunner - Exception caught during execution | |
| java.io.IOException: Stream closed | |
| at java.io.BufferedInputStream.getBufIfOpen(BufferedInputStream.java:170) ~[?:1.8.0_141] | |
| at java.io.BufferedInputStream.read1(BufferedInputStream.java:291) ~[?:1.8.0_141] | |
| at java.io.BufferedInputStream.read(BufferedInputStream.java:345) ~[?:1.8.0_141] | |
| at java.io.FilterInputStream.read(FilterInputStream.java:107) ~[?:1.8.0_141] | |
| at com.google.common.io.ByteStreams.copy(ByteStreams.java:175) ~[guava-16.0.1.jar:?] | |
| at io.druid.indexing.overlord.ForkingTaskRunner$1.call(ForkingTaskRunner.java:452) [druid-indexing-service-0.12.0-iap10.jar:0.12.0-iap10] | |
| at io.druid.indexing.overlord.ForkingTaskRunner$1.call(ForkingTaskRunner.java:224) [druid-indexing-service-0.12.0-iap10.jar:0.12.0-iap10] | |
| at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_141] | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_141] | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_141] | |
| at java.lang.Thread.run(Thread.java:748) [?:1.8.0_141] | |
| 2018-06-04T11:43:12,267 INFO [forking-task-runner-4] io.druid.indexing.overlord.ForkingTaskRunner - Removing task directory: var/druid/task/index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ghgdghfl | |
| 2018-06-04T11:43:12,271 INFO [qtp299684908-90] io.druid.indexing.overlord.ForkingTaskRunner - Ignoring request to cancel unknown task: index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ghgdghfl | |
| 2018-06-04T11:43:12,274 INFO [WorkerTaskManager-NoticeHandler] io.druid.indexing.worker.WorkerTaskManager - Job's finished. Completed [index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ghgdghfl] with status [FAILED] | |
| 2018-06-04T11:43:12,288 INFO [WorkerTaskManager-NoticeHandler] io.druid.indexing.worker.WorkerTaskManager - Task[index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn] started. | |
| 2018-06-04T11:43:12,289 INFO [forking-task-runner-2] io.druid.indexing.overlord.ForkingTaskRunner - Running command: java -cp /usr/local/imply-2.5.11/conf-quickstart/druid/middleManager:/usr/local/imply-2.5.11/conf-quickstart/druid/_common:/usr/local/imply-2.5.11/bin/../dist/resources:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-dbcp2-2.0.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/airline-0.7.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/janino-2.7.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-dataformat-smile-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-codec-http-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-proxy-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-jaxrs-smile-provider-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-module-jaxb-annotations-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/java-xmlbuilder-1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/javax.servlet-api-3.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/RoaringBitmap-0.5.18.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/guice-4.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/curator-framework-4.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-indexing-hadoop-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-annotations-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-handler-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-mapper-asl-1.9.13.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jersey-server-1.19.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/reactive-streams-1.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/avatica-metrics-1.10.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/derbynet-10.11.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-buffer-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/irc-api-1.0-0014.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-io-2.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aether-connector-file-0.9.0.M2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-lang-2.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/compress-lzf-1.0.4.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-codec-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-io-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-sql-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/plexus-interpolation-1.19.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-http-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jsr311-api-1.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/asm-5.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/bcprov-jdk15on-1.52.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/classmate-1.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/protobuf-java-3.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-client-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-pool-1.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-processing-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maven-repository-metadata-3.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jersey-core-1.19.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/javax.el-api-3.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-jq-0.0.7.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-indexing-service-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/async-http-client-netty-utils-2.0.37.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jcl-over-slf4j-1.7.12.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/hibernate-validator-5.1.3.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/plexus-utils-3.0.15.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/javax.el-3.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jersey-guice-1.19.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-transport-native-epoll-4.0.52.Final-linux-x86_64.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/lz4-1.3.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/antlr4-runtime-4.5.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/guava-16.0.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/tesla-aether-0.0.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/extendedset-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/log4j-slf4j-impl-2.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/slf4j-api-1.6.4.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jdbi-2.63.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-common-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-cli-1.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-codec-1.7.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maven-model-3.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aether-impl-0.9.0.M2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maven-settings-builder-3.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/joda-time-2.9.9.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-jaxrs-json-provider-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/httpclient-4.5.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aether-connector-okhttp-0.0.9.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-api-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/esri-geometry-api-2.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/derbytools-10.11.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/curator-client-4.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/log4j-jul-2.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-servlet-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/zookeeper-3.4.10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-util-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/curator-recipes-4.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-resolver-2.0.37.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-core-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/activation-1.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-server-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-security-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-hll-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/log4j-core-2.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maven-settings-3.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-pool2-2.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jets3t-0.9.4.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jvm-attach-api-1.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/xz-1.8.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/fastutil-8.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/objenesis-2.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maven-model-builder-3.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/curator-x-discovery-4.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/config-magic-0.9.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jline-0.9.94.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/guice-servlet-4.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/disruptor-3.3.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/log4j-1.2-api-2.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/derbyclient-10.11.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-services-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-common-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/asm-tree-5.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-datatype-joda-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-jaxrs-base-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-continuation-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/icu4j-54.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/calcite-core-1.15.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-dbcp-1.4.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/javax.inject-1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-databind-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/avatica-server-1.10.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jersey-servlet-1.19.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-core-asl-1.9.13.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-compiler-2.7.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/validation-api-1.1.0.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/base64-2.3.8.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jboss-logging-3.1.3.GA.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-math3-3.6.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/rhino-1.7R5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aether-util-0.9.0.M2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-resolver-dns-2.0.37.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/joni-2.1.11.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/java-util-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aws-java-sdk-core-1.10.77.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/guice-multibindings-4.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-3.10.6.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/async-http-client-2.0.37.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-datatype-guava-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aopalliance-1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aws-java-sdk-ec2-1.10.77.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/opencsv-2.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aether-api-0.9.0.M2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aether-spi-0.9.0.M2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-logging-1.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aggdesigner-algorithm-6.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-server-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/avatica-core-1.10.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jcodings-1.0.13.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-aws-common-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/asm-commons-5.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-all-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/geoip2-0.4.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/wagon-provider-api-2.4.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/caffeine-2.5.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-console-0.0.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-dataformat-cbor-2.5.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-lang3-3.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/httpcore-4.4.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maven-aether-provider-3.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/log4j-api-2.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jsr305-2.0.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/derby-10.11.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-codec-dns-2.0.37.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-reactive-streams-1.0.8.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/mapdb-1.0.8.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maxminddb-0.2.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-compress-1.16.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/json-path-2.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-servlets-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-transport-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/spymemcached-2.12.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/calcite-linq4j-1.15.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/okhttp-1.0.2.jar -server -Xms512m -Xmx512m -XX:MaxDirectMemorySize=1g -Duser.timezone=UTC -Dfile.encoding=UTF-8 -Djava.util.logging.manager=org.apache.logging.log4j.jul.LogManager -Ddruid.indexer.task.baseTaskDir=var/druid/task -Ddruid.processing.buffer.sizeBytes=50000000 -Ddruid.metadata.storage.connector.password=risk_preprod@123 -Ddruid.emitter.logging.logLevel=debug -Ddruid.emitter=logging -Ddruid.indexer.task.restoreTasksOnRestart=true -Duser.timezone=UTC -Dfile.encoding.pkg=sun.io -Ddruid.storage.storageDirectory=/druid/segments -Ddruid.selectors.coordinator.serviceName=druid/coordinator -Ddruid.extensions.directory=dist/druid/extensions -Ddruid.selectors.indexing.serviceName=druid/overlord -Ddruid.lookup.enableLookupSyncOnStartup=false -Ddruid.port=8091 -Ddruid.server.http.numThreads=12 -Ddruid.worker.capacity=10 -Ddruid.extensions.hadoopDependenciesDir=dist/druid/hadoop-dependencies -Ddruid.processing.numMergeBuffers=2 -Ddruid.processing.tmpDir=var/druid/processing -Ddruid.service=druid/middlemanager -Ddruid.metadata.storage.connector.user=risk_preprod -Ddruid.metadata.storage.type=mysql -Ddruid.metadata.storage.connector.connectURI=jdbc:mysql://10.12.0.153:3306/druid_preprod -Djava.io.tmpdir=var/tmp -Ddruid.extensions.loadList=["druid-histogram", "druid-datasketches", "druid-kafka-indexing-service", "mysql-metadata-storage", "druid-hdfs-storage", "druid-parser-route", "druid-avro-extensions"] -Ddruid.sql.enable=true -Ddruid.startup.logging.logProperties=true -Ddruid.processing.numThreads=1 -Ddruid.zk.service.host=10.12.0.6:2184 -Dhadoop.hadoop.tmp.dir=var/hadoop-tmp -Ddruid.monitoring.monitors=["io.druid.java.util.metrics.JvmMonitor"] -Ddruid.indexer.logs.directory=/druid/indexing-logs -Ddruid.zk.paths.base=/druid -Dfile.encoding=UTF-8 -Ddruid.indexer.task.defaultHadoopCoordinates=["org.apache.hadoop:hadoop-client:2.7.3"] -Ddruid.storage.type=hdfs -Ddruid.indexer.task.hadoopWorkingPath=var/druid/hadoop-tmp -Ddruid.indexer.logs.type=hdfs -Ddruid.metrics.emitter.dimension.dataSource=preprod-credit-invocation-history-kafka -Ddruid.metrics.emitter.dimension.taskId=index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn -Ddruid.host=iZuf6flaph02htekc965qjZ -Ddruid.port=8105 -Ddruid.tlsPort=-1 io.druid.cli.Main internal peon var/druid/task/index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn/task.json var/druid/task/index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn/1e4959c3-e5b2-4c64-a39c-86d9bd67c545/status.json | |
| 2018-06-04T11:43:12,294 INFO [forking-task-runner-2] io.druid.indexing.overlord.TaskRunnerUtils - Task [index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn] location changed to [TaskLocation{host='iZuf6flaph02htekc965qjZ', port=8105, tlsPort=-1}]. | |
| 2018-06-04T11:43:12,294 INFO [forking-task-runner-2] io.druid.indexing.overlord.TaskRunnerUtils - Task [index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn] status changed to [RUNNING]. | |
| 2018-06-04T11:43:12,294 INFO [forking-task-runner-2] io.druid.indexing.overlord.ForkingTaskRunner - Logging task index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn output to: var/druid/task/index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn/log | |
| 2018-06-04T11:43:42,394 INFO [qtp299684908-89] io.druid.indexing.overlord.ForkingTaskRunner - Killing process for task: index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_kbmeemfo | |
| 2018-06-04T11:43:42,395 INFO [forking-task-runner-8] io.druid.storage.hdfs.tasklog.HdfsTaskLogs - Writing task log to: /druid/indexing-logs/index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_kbmeemfo | |
| 2018-06-04T11:43:42,403 INFO [qtp299684908-88] io.druid.indexing.overlord.ForkingTaskRunner - Killing process for task: index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_kbmeemfo | |
| 2018-06-04T11:43:42,410 INFO [qtp299684908-86] io.druid.indexing.overlord.ForkingTaskRunner - Killing process for task: index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_kbmeemfo | |
| 2018-06-04T11:43:42,413 INFO [forking-task-runner-8] io.druid.storage.hdfs.tasklog.HdfsTaskLogs - Wrote task log to: /druid/indexing-logs/index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_kbmeemfo | |
| 2018-06-04T11:43:42,413 INFO [forking-task-runner-8] io.druid.indexing.overlord.ForkingTaskRunner - Exception caught during execution | |
| java.io.IOException: Stream closed | |
| at java.io.BufferedInputStream.getBufIfOpen(BufferedInputStream.java:170) ~[?:1.8.0_141] | |
| at java.io.BufferedInputStream.read1(BufferedInputStream.java:291) ~[?:1.8.0_141] | |
| at java.io.BufferedInputStream.read(BufferedInputStream.java:345) ~[?:1.8.0_141] | |
| at java.io.FilterInputStream.read(FilterInputStream.java:107) ~[?:1.8.0_141] | |
| at com.google.common.io.ByteStreams.copy(ByteStreams.java:175) ~[guava-16.0.1.jar:?] | |
| at io.druid.indexing.overlord.ForkingTaskRunner$1.call(ForkingTaskRunner.java:452) [druid-indexing-service-0.12.0-iap10.jar:0.12.0-iap10] | |
| at io.druid.indexing.overlord.ForkingTaskRunner$1.call(ForkingTaskRunner.java:224) [druid-indexing-service-0.12.0-iap10.jar:0.12.0-iap10] | |
| at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_141] | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_141] | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_141] | |
| at java.lang.Thread.run(Thread.java:748) [?:1.8.0_141] | |
| 2018-06-04T11:43:42,414 INFO [forking-task-runner-8] io.druid.indexing.overlord.ForkingTaskRunner - Removing task directory: var/druid/task/index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_kbmeemfo | |
| 2018-06-04T11:43:42,423 INFO [qtp299684908-78] io.druid.indexing.overlord.ForkingTaskRunner - Ignoring request to cancel unknown task: index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_kbmeemfo | |
| 2018-06-04T11:43:42,424 INFO [WorkerTaskManager-NoticeHandler] io.druid.indexing.worker.WorkerTaskManager - Job's finished. Completed [index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_kbmeemfo] with status [FAILED] | |
| 2018-06-04T11:43:42,437 INFO [WorkerTaskManager-NoticeHandler] io.druid.indexing.worker.WorkerTaskManager - Task[index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch] started. | |
| 2018-06-04T11:43:42,438 INFO [forking-task-runner-3] io.druid.indexing.overlord.ForkingTaskRunner - Running command: java -cp /usr/local/imply-2.5.11/conf-quickstart/druid/middleManager:/usr/local/imply-2.5.11/conf-quickstart/druid/_common:/usr/local/imply-2.5.11/bin/../dist/resources:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-dbcp2-2.0.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/airline-0.7.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/janino-2.7.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-dataformat-smile-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-codec-http-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-proxy-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-jaxrs-smile-provider-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-module-jaxb-annotations-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/java-xmlbuilder-1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/javax.servlet-api-3.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/RoaringBitmap-0.5.18.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/guice-4.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/curator-framework-4.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-indexing-hadoop-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-annotations-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-handler-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-mapper-asl-1.9.13.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jersey-server-1.19.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/reactive-streams-1.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/avatica-metrics-1.10.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/derbynet-10.11.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-buffer-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/irc-api-1.0-0014.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-io-2.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aether-connector-file-0.9.0.M2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-lang-2.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/compress-lzf-1.0.4.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-codec-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-io-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-sql-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/plexus-interpolation-1.19.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-http-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jsr311-api-1.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/asm-5.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/bcprov-jdk15on-1.52.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/classmate-1.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/protobuf-java-3.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-client-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-pool-1.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-processing-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maven-repository-metadata-3.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jersey-core-1.19.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/javax.el-api-3.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-jq-0.0.7.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-indexing-service-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/async-http-client-netty-utils-2.0.37.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jcl-over-slf4j-1.7.12.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/hibernate-validator-5.1.3.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/plexus-utils-3.0.15.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/javax.el-3.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jersey-guice-1.19.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-transport-native-epoll-4.0.52.Final-linux-x86_64.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/lz4-1.3.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/antlr4-runtime-4.5.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/guava-16.0.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/tesla-aether-0.0.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/extendedset-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/log4j-slf4j-impl-2.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/slf4j-api-1.6.4.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jdbi-2.63.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-common-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-cli-1.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-codec-1.7.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maven-model-3.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aether-impl-0.9.0.M2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maven-settings-builder-3.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/joda-time-2.9.9.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-jaxrs-json-provider-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/httpclient-4.5.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aether-connector-okhttp-0.0.9.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-api-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/esri-geometry-api-2.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/derbytools-10.11.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/curator-client-4.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/log4j-jul-2.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-servlet-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/zookeeper-3.4.10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-util-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/curator-recipes-4.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-resolver-2.0.37.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-core-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/activation-1.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-server-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-security-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-hll-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/log4j-core-2.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maven-settings-3.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-pool2-2.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jets3t-0.9.4.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jvm-attach-api-1.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/xz-1.8.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/fastutil-8.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/objenesis-2.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maven-model-builder-3.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/curator-x-discovery-4.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/config-magic-0.9.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jline-0.9.94.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/guice-servlet-4.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/disruptor-3.3.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/log4j-1.2-api-2.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/derbyclient-10.11.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-services-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-common-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/asm-tree-5.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-datatype-joda-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-jaxrs-base-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-continuation-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/icu4j-54.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/calcite-core-1.15.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-dbcp-1.4.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/javax.inject-1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-databind-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/avatica-server-1.10.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jersey-servlet-1.19.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-core-asl-1.9.13.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-compiler-2.7.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/validation-api-1.1.0.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/base64-2.3.8.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jboss-logging-3.1.3.GA.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-math3-3.6.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/rhino-1.7R5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aether-util-0.9.0.M2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-resolver-dns-2.0.37.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/joni-2.1.11.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/java-util-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aws-java-sdk-core-1.10.77.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/guice-multibindings-4.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-3.10.6.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/async-http-client-2.0.37.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-datatype-guava-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aopalliance-1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aws-java-sdk-ec2-1.10.77.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/opencsv-2.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aether-api-0.9.0.M2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aether-spi-0.9.0.M2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-logging-1.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aggdesigner-algorithm-6.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-server-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/avatica-core-1.10.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jcodings-1.0.13.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-aws-common-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/asm-commons-5.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-all-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/geoip2-0.4.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/wagon-provider-api-2.4.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/caffeine-2.5.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-console-0.0.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-dataformat-cbor-2.5.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-lang3-3.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/httpcore-4.4.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maven-aether-provider-3.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/log4j-api-2.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jsr305-2.0.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/derby-10.11.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-codec-dns-2.0.37.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-reactive-streams-1.0.8.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/mapdb-1.0.8.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maxminddb-0.2.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-compress-1.16.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/json-path-2.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-servlets-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-transport-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/spymemcached-2.12.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/calcite-linq4j-1.15.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/okhttp-1.0.2.jar -server -Xms512m -Xmx512m -XX:MaxDirectMemorySize=1g -Duser.timezone=UTC -Dfile.encoding=UTF-8 -Djava.util.logging.manager=org.apache.logging.log4j.jul.LogManager -Ddruid.indexer.task.baseTaskDir=var/druid/task -Ddruid.processing.buffer.sizeBytes=50000000 -Ddruid.metadata.storage.connector.password=risk_preprod@123 -Ddruid.emitter.logging.logLevel=debug -Ddruid.emitter=logging -Ddruid.indexer.task.restoreTasksOnRestart=true -Duser.timezone=UTC -Dfile.encoding.pkg=sun.io -Ddruid.storage.storageDirectory=/druid/segments -Ddruid.selectors.coordinator.serviceName=druid/coordinator -Ddruid.extensions.directory=dist/druid/extensions -Ddruid.selectors.indexing.serviceName=druid/overlord -Ddruid.lookup.enableLookupSyncOnStartup=false -Ddruid.port=8091 -Ddruid.server.http.numThreads=12 -Ddruid.worker.capacity=10 -Ddruid.extensions.hadoopDependenciesDir=dist/druid/hadoop-dependencies -Ddruid.processing.numMergeBuffers=2 -Ddruid.processing.tmpDir=var/druid/processing -Ddruid.service=druid/middlemanager -Ddruid.metadata.storage.connector.user=risk_preprod -Ddruid.metadata.storage.type=mysql -Ddruid.metadata.storage.connector.connectURI=jdbc:mysql://10.12.0.153:3306/druid_preprod -Djava.io.tmpdir=var/tmp -Ddruid.extensions.loadList=["druid-histogram", "druid-datasketches", "druid-kafka-indexing-service", "mysql-metadata-storage", "druid-hdfs-storage", "druid-parser-route", "druid-avro-extensions"] -Ddruid.sql.enable=true -Ddruid.startup.logging.logProperties=true -Ddruid.processing.numThreads=1 -Ddruid.zk.service.host=10.12.0.6:2184 -Dhadoop.hadoop.tmp.dir=var/hadoop-tmp -Ddruid.monitoring.monitors=["io.druid.java.util.metrics.JvmMonitor"] -Ddruid.indexer.logs.directory=/druid/indexing-logs -Ddruid.zk.paths.base=/druid -Dfile.encoding=UTF-8 -Ddruid.indexer.task.defaultHadoopCoordinates=["org.apache.hadoop:hadoop-client:2.7.3"] -Ddruid.storage.type=hdfs -Ddruid.indexer.task.hadoopWorkingPath=var/druid/hadoop-tmp -Ddruid.indexer.logs.type=hdfs -Ddruid.metrics.emitter.dimension.dataSource=preprod-payment-event-plan-repayment-kafka -Ddruid.metrics.emitter.dimension.taskId=index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch -Ddruid.host=iZuf6flaph02htekc965qjZ -Ddruid.port=8100 -Ddruid.tlsPort=-1 io.druid.cli.Main internal peon var/druid/task/index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch/task.json var/druid/task/index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch/0bdcf11c-fac8-4001-84d6-7e9daf830d37/status.json | |
| 2018-06-04T11:43:42,441 INFO [forking-task-runner-3] io.druid.indexing.overlord.TaskRunnerUtils - Task [index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch] location changed to [TaskLocation{host='iZuf6flaph02htekc965qjZ', port=8100, tlsPort=-1}]. | |
| 2018-06-04T11:43:42,441 INFO [forking-task-runner-3] io.druid.indexing.overlord.TaskRunnerUtils - Task [index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch] status changed to [RUNNING]. | |
| 2018-06-04T11:43:42,441 INFO [forking-task-runner-3] io.druid.indexing.overlord.ForkingTaskRunner - Logging task index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch output to: var/druid/task/index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch/log | |
| 2018-06-04T11:43:42,449 INFO [qtp299684908-96] io.druid.indexing.overlord.ForkingTaskRunner - Killing process for task: index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_bicnekon | |
| 2018-06-04T11:43:42,450 INFO [forking-task-runner-6] io.druid.storage.hdfs.tasklog.HdfsTaskLogs - Writing task log to: /druid/indexing-logs/index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_bicnekon | |
| 2018-06-04T11:43:42,461 INFO [qtp299684908-93] io.druid.indexing.overlord.ForkingTaskRunner - Killing process for task: index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_pdiebbnm | |
| 2018-06-04T11:43:42,473 INFO [forking-task-runner-1] io.druid.storage.hdfs.tasklog.HdfsTaskLogs - Writing task log to: /druid/indexing-logs/index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_pdiebbnm | |
| 2018-06-04T11:43:42,525 INFO [qtp299684908-92] io.druid.indexing.overlord.ForkingTaskRunner - Killing process for task: index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_bicnekon | |
| 2018-06-04T11:43:42,538 INFO [qtp299684908-97] io.druid.indexing.overlord.ForkingTaskRunner - Killing process for task: index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_pdiebbnm | |
| 2018-06-04T11:43:42,541 INFO [forking-task-runner-6] io.druid.storage.hdfs.tasklog.HdfsTaskLogs - Wrote task log to: /druid/indexing-logs/index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_bicnekon | |
| 2018-06-04T11:43:42,541 INFO [forking-task-runner-6] io.druid.indexing.overlord.ForkingTaskRunner - Exception caught during execution | |
| java.io.IOException: Stream closed | |
| at java.io.BufferedInputStream.getBufIfOpen(BufferedInputStream.java:170) ~[?:1.8.0_141] | |
| at java.io.BufferedInputStream.read1(BufferedInputStream.java:291) ~[?:1.8.0_141] | |
| at java.io.BufferedInputStream.read(BufferedInputStream.java:345) ~[?:1.8.0_141] | |
| at java.io.FilterInputStream.read(FilterInputStream.java:107) ~[?:1.8.0_141] | |
| at com.google.common.io.ByteStreams.copy(ByteStreams.java:175) ~[guava-16.0.1.jar:?] | |
| at io.druid.indexing.overlord.ForkingTaskRunner$1.call(ForkingTaskRunner.java:452) [druid-indexing-service-0.12.0-iap10.jar:0.12.0-iap10] | |
| at io.druid.indexing.overlord.ForkingTaskRunner$1.call(ForkingTaskRunner.java:224) [druid-indexing-service-0.12.0-iap10.jar:0.12.0-iap10] | |
| at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_141] | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_141] | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_141] | |
| at java.lang.Thread.run(Thread.java:748) [?:1.8.0_141] | |
| 2018-06-04T11:43:42,541 INFO [forking-task-runner-6] io.druid.indexing.overlord.ForkingTaskRunner - Removing task directory: var/druid/task/index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_bicnekon | |
| 2018-06-04T11:43:42,550 INFO [WorkerTaskManager-NoticeHandler] io.druid.indexing.worker.WorkerTaskManager - Job's finished. Completed [index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_bicnekon] with status [FAILED] | |
| 2018-06-04T11:43:42,575 INFO [qtp299684908-80] io.druid.indexing.overlord.ForkingTaskRunner - Killing process for task: index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_pdiebbnm | |
| 2018-06-04T11:43:42,580 INFO [forking-task-runner-1] io.druid.storage.hdfs.tasklog.HdfsTaskLogs - Wrote task log to: /druid/indexing-logs/index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_pdiebbnm | |
| 2018-06-04T11:43:42,580 INFO [forking-task-runner-1] io.druid.indexing.overlord.ForkingTaskRunner - Exception caught during execution | |
| java.io.IOException: Stream closed | |
| at java.io.BufferedInputStream.getBufIfOpen(BufferedInputStream.java:170) ~[?:1.8.0_141] | |
| at java.io.BufferedInputStream.read1(BufferedInputStream.java:291) ~[?:1.8.0_141] | |
| at java.io.BufferedInputStream.read(BufferedInputStream.java:345) ~[?:1.8.0_141] | |
| at java.io.FilterInputStream.read(FilterInputStream.java:107) ~[?:1.8.0_141] | |
| at com.google.common.io.ByteStreams.copy(ByteStreams.java:175) ~[guava-16.0.1.jar:?] | |
| at io.druid.indexing.overlord.ForkingTaskRunner$1.call(ForkingTaskRunner.java:452) [druid-indexing-service-0.12.0-iap10.jar:0.12.0-iap10] | |
| at io.druid.indexing.overlord.ForkingTaskRunner$1.call(ForkingTaskRunner.java:224) [druid-indexing-service-0.12.0-iap10.jar:0.12.0-iap10] | |
| at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_141] | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_141] | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_141] | |
| at java.lang.Thread.run(Thread.java:748) [?:1.8.0_141] | |
| 2018-06-04T11:43:42,580 INFO [forking-task-runner-1] io.druid.indexing.overlord.ForkingTaskRunner - Removing task directory: var/druid/task/index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_pdiebbnm | |
| 2018-06-04T11:43:42,582 INFO [WorkerTaskManager-NoticeHandler] io.druid.indexing.worker.WorkerTaskManager - Task[index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch] started. | |
| 2018-06-04T11:43:42,582 INFO [forking-task-runner-0] io.druid.indexing.overlord.ForkingTaskRunner - Running command: java -cp /usr/local/imply-2.5.11/conf-quickstart/druid/middleManager:/usr/local/imply-2.5.11/conf-quickstart/druid/_common:/usr/local/imply-2.5.11/bin/../dist/resources:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-dbcp2-2.0.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/airline-0.7.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/janino-2.7.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-dataformat-smile-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-codec-http-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-proxy-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-jaxrs-smile-provider-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-module-jaxb-annotations-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/java-xmlbuilder-1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/javax.servlet-api-3.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/RoaringBitmap-0.5.18.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/guice-4.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/curator-framework-4.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-indexing-hadoop-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-annotations-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-handler-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-mapper-asl-1.9.13.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jersey-server-1.19.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/reactive-streams-1.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/avatica-metrics-1.10.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/derbynet-10.11.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-buffer-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/irc-api-1.0-0014.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-io-2.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aether-connector-file-0.9.0.M2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-lang-2.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/compress-lzf-1.0.4.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-codec-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-io-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-sql-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/plexus-interpolation-1.19.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-http-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jsr311-api-1.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/asm-5.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/bcprov-jdk15on-1.52.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/classmate-1.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/protobuf-java-3.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-client-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-pool-1.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-processing-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maven-repository-metadata-3.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jersey-core-1.19.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/javax.el-api-3.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-jq-0.0.7.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-indexing-service-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/async-http-client-netty-utils-2.0.37.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jcl-over-slf4j-1.7.12.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/hibernate-validator-5.1.3.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/plexus-utils-3.0.15.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/javax.el-3.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jersey-guice-1.19.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-transport-native-epoll-4.0.52.Final-linux-x86_64.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/lz4-1.3.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/antlr4-runtime-4.5.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/guava-16.0.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/tesla-aether-0.0.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/extendedset-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/log4j-slf4j-impl-2.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/slf4j-api-1.6.4.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jdbi-2.63.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-common-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-cli-1.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-codec-1.7.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maven-model-3.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aether-impl-0.9.0.M2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maven-settings-builder-3.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/joda-time-2.9.9.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-jaxrs-json-provider-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/httpclient-4.5.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aether-connector-okhttp-0.0.9.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-api-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/esri-geometry-api-2.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/derbytools-10.11.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/curator-client-4.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/log4j-jul-2.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-servlet-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/zookeeper-3.4.10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-util-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/curator-recipes-4.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-resolver-2.0.37.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-core-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/activation-1.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-server-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-security-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-hll-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/log4j-core-2.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maven-settings-3.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-pool2-2.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jets3t-0.9.4.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jvm-attach-api-1.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/xz-1.8.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/fastutil-8.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/objenesis-2.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maven-model-builder-3.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/curator-x-discovery-4.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/config-magic-0.9.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jline-0.9.94.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/guice-servlet-4.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/disruptor-3.3.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/log4j-1.2-api-2.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/derbyclient-10.11.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-services-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-common-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/asm-tree-5.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-datatype-joda-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-jaxrs-base-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-continuation-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/icu4j-54.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/calcite-core-1.15.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-dbcp-1.4.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/javax.inject-1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-databind-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/avatica-server-1.10.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jersey-servlet-1.19.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-core-asl-1.9.13.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-compiler-2.7.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/validation-api-1.1.0.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/base64-2.3.8.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jboss-logging-3.1.3.GA.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-math3-3.6.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/rhino-1.7R5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aether-util-0.9.0.M2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-resolver-dns-2.0.37.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/joni-2.1.11.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/java-util-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aws-java-sdk-core-1.10.77.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/guice-multibindings-4.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-3.10.6.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/async-http-client-2.0.37.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-datatype-guava-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aopalliance-1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aws-java-sdk-ec2-1.10.77.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/opencsv-2.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aether-api-0.9.0.M2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aether-spi-0.9.0.M2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-logging-1.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aggdesigner-algorithm-6.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-server-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/avatica-core-1.10.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jcodings-1.0.13.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-aws-common-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/asm-commons-5.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-all-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/geoip2-0.4.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/wagon-provider-api-2.4.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/caffeine-2.5.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-console-0.0.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-dataformat-cbor-2.5.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-lang3-3.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/httpcore-4.4.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maven-aether-provider-3.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/log4j-api-2.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jsr305-2.0.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/derby-10.11.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-codec-dns-2.0.37.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-reactive-streams-1.0.8.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/mapdb-1.0.8.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maxminddb-0.2.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-compress-1.16.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/json-path-2.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-servlets-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-transport-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/spymemcached-2.12.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/calcite-linq4j-1.15.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/okhttp-1.0.2.jar -server -Xms512m -Xmx512m -XX:MaxDirectMemorySize=1g -Duser.timezone=UTC -Dfile.encoding=UTF-8 -Djava.util.logging.manager=org.apache.logging.log4j.jul.LogManager -Ddruid.indexer.task.baseTaskDir=var/druid/task -Ddruid.processing.buffer.sizeBytes=50000000 -Ddruid.metadata.storage.connector.password=risk_preprod@123 -Ddruid.emitter.logging.logLevel=debug -Ddruid.emitter=logging -Ddruid.indexer.task.restoreTasksOnRestart=true -Duser.timezone=UTC -Dfile.encoding.pkg=sun.io -Ddruid.storage.storageDirectory=/druid/segments -Ddruid.selectors.coordinator.serviceName=druid/coordinator -Ddruid.extensions.directory=dist/druid/extensions -Ddruid.selectors.indexing.serviceName=druid/overlord -Ddruid.lookup.enableLookupSyncOnStartup=false -Ddruid.port=8091 -Ddruid.server.http.numThreads=12 -Ddruid.worker.capacity=10 -Ddruid.extensions.hadoopDependenciesDir=dist/druid/hadoop-dependencies -Ddruid.processing.numMergeBuffers=2 -Ddruid.processing.tmpDir=var/druid/processing -Ddruid.service=druid/middlemanager -Ddruid.metadata.storage.connector.user=risk_preprod -Ddruid.metadata.storage.type=mysql -Ddruid.metadata.storage.connector.connectURI=jdbc:mysql://10.12.0.153:3306/druid_preprod -Djava.io.tmpdir=var/tmp -Ddruid.extensions.loadList=["druid-histogram", "druid-datasketches", "druid-kafka-indexing-service", "mysql-metadata-storage", "druid-hdfs-storage", "druid-parser-route", "druid-avro-extensions"] -Ddruid.sql.enable=true -Ddruid.startup.logging.logProperties=true -Ddruid.processing.numThreads=1 -Ddruid.zk.service.host=10.12.0.6:2184 -Dhadoop.hadoop.tmp.dir=var/hadoop-tmp -Ddruid.monitoring.monitors=["io.druid.java.util.metrics.JvmMonitor"] -Ddruid.indexer.logs.directory=/druid/indexing-logs -Ddruid.zk.paths.base=/druid -Dfile.encoding=UTF-8 -Ddruid.indexer.task.defaultHadoopCoordinates=["org.apache.hadoop:hadoop-client:2.7.3"] -Ddruid.storage.type=hdfs -Ddruid.indexer.task.hadoopWorkingPath=var/druid/hadoop-tmp -Ddruid.indexer.logs.type=hdfs -Ddruid.metrics.emitter.dimension.dataSource=preprod-loanend-event-cancel-plan-repayment-kafka -Ddruid.metrics.emitter.dimension.taskId=index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch -Ddruid.host=iZuf6flaph02htekc965qjZ -Ddruid.port=8101 -Ddruid.tlsPort=-1 io.druid.cli.Main internal peon var/druid/task/index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch/task.json var/druid/task/index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch/b58be3de-efec-4bcb-828f-821e8da75ac0/status.json | |
| 2018-06-04T11:43:42,589 INFO [WorkerTaskManager-NoticeHandler] io.druid.indexing.worker.WorkerTaskManager - Job's finished. Completed [index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_pdiebbnm] with status [FAILED] | |
| 2018-06-04T11:43:42,591 INFO [forking-task-runner-0] io.druid.indexing.overlord.TaskRunnerUtils - Task [index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch] location changed to [TaskLocation{host='iZuf6flaph02htekc965qjZ', port=8101, tlsPort=-1}]. | |
| 2018-06-04T11:43:42,591 INFO [forking-task-runner-0] io.druid.indexing.overlord.TaskRunnerUtils - Task [index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch] status changed to [RUNNING]. | |
| 2018-06-04T11:43:42,592 INFO [forking-task-runner-0] io.druid.indexing.overlord.ForkingTaskRunner - Logging task index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch output to: var/druid/task/index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch/log | |
| 2018-06-04T11:43:42,603 INFO [WorkerTaskManager-NoticeHandler] io.druid.indexing.worker.WorkerTaskManager - Task[index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii] started. | |
| 2018-06-04T11:43:42,604 INFO [forking-task-runner-5] io.druid.indexing.overlord.ForkingTaskRunner - Running command: java -cp /usr/local/imply-2.5.11/conf-quickstart/druid/middleManager:/usr/local/imply-2.5.11/conf-quickstart/druid/_common:/usr/local/imply-2.5.11/bin/../dist/resources:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-dbcp2-2.0.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/airline-0.7.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/janino-2.7.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-dataformat-smile-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-codec-http-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-proxy-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-jaxrs-smile-provider-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-module-jaxb-annotations-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/java-xmlbuilder-1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/javax.servlet-api-3.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/RoaringBitmap-0.5.18.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/guice-4.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/curator-framework-4.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-indexing-hadoop-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-annotations-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-handler-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-mapper-asl-1.9.13.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jersey-server-1.19.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/reactive-streams-1.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/avatica-metrics-1.10.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/derbynet-10.11.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-buffer-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/irc-api-1.0-0014.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-io-2.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aether-connector-file-0.9.0.M2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-lang-2.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/compress-lzf-1.0.4.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-codec-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-io-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-sql-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/plexus-interpolation-1.19.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-http-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jsr311-api-1.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/asm-5.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/bcprov-jdk15on-1.52.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/classmate-1.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/protobuf-java-3.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-client-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-pool-1.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-processing-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maven-repository-metadata-3.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jersey-core-1.19.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/javax.el-api-3.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-jq-0.0.7.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-indexing-service-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/async-http-client-netty-utils-2.0.37.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jcl-over-slf4j-1.7.12.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/hibernate-validator-5.1.3.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/plexus-utils-3.0.15.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/javax.el-3.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jersey-guice-1.19.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-transport-native-epoll-4.0.52.Final-linux-x86_64.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/lz4-1.3.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/antlr4-runtime-4.5.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/guava-16.0.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/tesla-aether-0.0.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/extendedset-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/log4j-slf4j-impl-2.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/slf4j-api-1.6.4.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jdbi-2.63.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-common-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-cli-1.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-codec-1.7.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maven-model-3.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aether-impl-0.9.0.M2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maven-settings-builder-3.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/joda-time-2.9.9.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-jaxrs-json-provider-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/httpclient-4.5.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aether-connector-okhttp-0.0.9.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-api-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/esri-geometry-api-2.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/derbytools-10.11.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/curator-client-4.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/log4j-jul-2.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-servlet-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/zookeeper-3.4.10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-util-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/curator-recipes-4.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-resolver-2.0.37.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-core-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/activation-1.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-server-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-security-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-hll-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/log4j-core-2.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maven-settings-3.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-pool2-2.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jets3t-0.9.4.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jvm-attach-api-1.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/xz-1.8.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/fastutil-8.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/objenesis-2.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maven-model-builder-3.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/curator-x-discovery-4.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/config-magic-0.9.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jline-0.9.94.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/guice-servlet-4.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/disruptor-3.3.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/log4j-1.2-api-2.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/derbyclient-10.11.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-services-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-common-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/asm-tree-5.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-datatype-joda-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-jaxrs-base-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-continuation-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/icu4j-54.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/calcite-core-1.15.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-dbcp-1.4.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/javax.inject-1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-databind-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/avatica-server-1.10.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jersey-servlet-1.19.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-core-asl-1.9.13.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-compiler-2.7.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/validation-api-1.1.0.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/base64-2.3.8.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jboss-logging-3.1.3.GA.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-math3-3.6.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/rhino-1.7R5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aether-util-0.9.0.M2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-resolver-dns-2.0.37.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/joni-2.1.11.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/java-util-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aws-java-sdk-core-1.10.77.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/guice-multibindings-4.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-3.10.6.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/async-http-client-2.0.37.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-datatype-guava-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aopalliance-1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aws-java-sdk-ec2-1.10.77.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/opencsv-2.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aether-api-0.9.0.M2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aether-spi-0.9.0.M2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-logging-1.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aggdesigner-algorithm-6.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-server-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/avatica-core-1.10.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jcodings-1.0.13.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-aws-common-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/asm-commons-5.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-all-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/geoip2-0.4.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/wagon-provider-api-2.4.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/caffeine-2.5.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-console-0.0.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-dataformat-cbor-2.5.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-lang3-3.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/httpcore-4.4.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maven-aether-provider-3.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/log4j-api-2.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jsr305-2.0.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/derby-10.11.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-codec-dns-2.0.37.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-reactive-streams-1.0.8.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/mapdb-1.0.8.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maxminddb-0.2.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-compress-1.16.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/json-path-2.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-servlets-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-transport-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/spymemcached-2.12.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/calcite-linq4j-1.15.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/okhttp-1.0.2.jar -server -Xms512m -Xmx512m -XX:MaxDirectMemorySize=1g -Duser.timezone=UTC -Dfile.encoding=UTF-8 -Djava.util.logging.manager=org.apache.logging.log4j.jul.LogManager -Ddruid.indexer.task.baseTaskDir=var/druid/task -Ddruid.processing.buffer.sizeBytes=50000000 -Ddruid.metadata.storage.connector.password=risk_preprod@123 -Ddruid.emitter.logging.logLevel=debug -Ddruid.emitter=logging -Ddruid.indexer.task.restoreTasksOnRestart=true -Duser.timezone=UTC -Dfile.encoding.pkg=sun.io -Ddruid.storage.storageDirectory=/druid/segments -Ddruid.selectors.coordinator.serviceName=druid/coordinator -Ddruid.extensions.directory=dist/druid/extensions -Ddruid.selectors.indexing.serviceName=druid/overlord -Ddruid.lookup.enableLookupSyncOnStartup=false -Ddruid.port=8091 -Ddruid.server.http.numThreads=12 -Ddruid.worker.capacity=10 -Ddruid.extensions.hadoopDependenciesDir=dist/druid/hadoop-dependencies -Ddruid.processing.numMergeBuffers=2 -Ddruid.processing.tmpDir=var/druid/processing -Ddruid.service=druid/middlemanager -Ddruid.metadata.storage.connector.user=risk_preprod -Ddruid.metadata.storage.type=mysql -Ddruid.metadata.storage.connector.connectURI=jdbc:mysql://10.12.0.153:3306/druid_preprod -Djava.io.tmpdir=var/tmp -Ddruid.extensions.loadList=["druid-histogram", "druid-datasketches", "druid-kafka-indexing-service", "mysql-metadata-storage", "druid-hdfs-storage", "druid-parser-route", "druid-avro-extensions"] -Ddruid.sql.enable=true -Ddruid.startup.logging.logProperties=true -Ddruid.processing.numThreads=1 -Ddruid.zk.service.host=10.12.0.6:2184 -Dhadoop.hadoop.tmp.dir=var/hadoop-tmp -Ddruid.monitoring.monitors=["io.druid.java.util.metrics.JvmMonitor"] -Ddruid.indexer.logs.directory=/druid/indexing-logs -Ddruid.zk.paths.base=/druid -Dfile.encoding=UTF-8 -Ddruid.indexer.task.defaultHadoopCoordinates=["org.apache.hadoop:hadoop-client:2.7.3"] -Ddruid.storage.type=hdfs -Ddruid.indexer.task.hadoopWorkingPath=var/druid/hadoop-tmp -Ddruid.indexer.logs.type=hdfs -Ddruid.metrics.emitter.dimension.dataSource=preprod-overdue-event-kafka -Ddruid.metrics.emitter.dimension.taskId=index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii -Ddruid.host=iZuf6flaph02htekc965qjZ -Ddruid.port=8102 -Ddruid.tlsPort=-1 io.druid.cli.Main internal peon var/druid/task/index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii/task.json var/druid/task/index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii/cccb01f5-29bd-421d-8b76-43e856010d10/status.json | |
| 2018-06-04T11:43:42,612 INFO [forking-task-runner-5] io.druid.indexing.overlord.TaskRunnerUtils - Task [index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii] location changed to [TaskLocation{host='iZuf6flaph02htekc965qjZ', port=8102, tlsPort=-1}]. | |
| 2018-06-04T11:43:42,612 INFO [forking-task-runner-5] io.druid.indexing.overlord.TaskRunnerUtils - Task [index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii] status changed to [RUNNING]. | |
| 2018-06-04T11:43:42,612 INFO [forking-task-runner-5] io.druid.indexing.overlord.ForkingTaskRunner - Logging task index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii output to: var/druid/task/index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii/log | |
| 2018-06-04T11:44:12,310 INFO [qtp299684908-83] io.druid.indexing.overlord.ForkingTaskRunner - Killing process for task: index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_bjoellcn | |
| 2018-06-04T11:44:12,311 INFO [forking-task-runner-9] io.druid.storage.hdfs.tasklog.HdfsTaskLogs - Writing task log to: /druid/indexing-logs/index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_bjoellcn | |
| 2018-06-04T11:44:12,326 INFO [qtp299684908-84] io.druid.indexing.overlord.ForkingTaskRunner - Killing process for task: index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_bjoellcn | |
| 2018-06-04T11:44:12,339 INFO [forking-task-runner-9] io.druid.storage.hdfs.tasklog.HdfsTaskLogs - Wrote task log to: /druid/indexing-logs/index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_bjoellcn | |
| 2018-06-04T11:44:12,340 INFO [forking-task-runner-9] io.druid.indexing.overlord.ForkingTaskRunner - Exception caught during execution | |
| java.io.IOException: Stream closed | |
| at java.io.BufferedInputStream.getBufIfOpen(BufferedInputStream.java:170) ~[?:1.8.0_141] | |
| at java.io.BufferedInputStream.read1(BufferedInputStream.java:291) ~[?:1.8.0_141] | |
| at java.io.BufferedInputStream.read(BufferedInputStream.java:345) ~[?:1.8.0_141] | |
| at java.io.FilterInputStream.read(FilterInputStream.java:107) ~[?:1.8.0_141] | |
| at com.google.common.io.ByteStreams.copy(ByteStreams.java:175) ~[guava-16.0.1.jar:?] | |
| at io.druid.indexing.overlord.ForkingTaskRunner$1.call(ForkingTaskRunner.java:452) [druid-indexing-service-0.12.0-iap10.jar:0.12.0-iap10] | |
| at io.druid.indexing.overlord.ForkingTaskRunner$1.call(ForkingTaskRunner.java:224) [druid-indexing-service-0.12.0-iap10.jar:0.12.0-iap10] | |
| at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_141] | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_141] | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_141] | |
| at java.lang.Thread.run(Thread.java:748) [?:1.8.0_141] | |
| 2018-06-04T11:44:12,340 INFO [forking-task-runner-9] io.druid.indexing.overlord.ForkingTaskRunner - Removing task directory: var/druid/task/index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_bjoellcn | |
| 2018-06-04T11:44:12,343 INFO [qtp299684908-85] io.druid.indexing.overlord.ForkingTaskRunner - Ignoring request to cancel unknown task: index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_bjoellcn | |
| 2018-06-04T11:44:12,343 INFO [WorkerTaskManager-NoticeHandler] io.druid.indexing.worker.WorkerTaskManager - Job's finished. Completed [index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_bjoellcn] with status [FAILED] | |
| 2018-06-04T11:44:12,360 INFO [WorkerTaskManager-NoticeHandler] io.druid.indexing.worker.WorkerTaskManager - Task[index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj] started. | |
| 2018-06-04T11:44:12,361 INFO [forking-task-runner-4] io.druid.indexing.overlord.ForkingTaskRunner - Running command: java -cp /usr/local/imply-2.5.11/conf-quickstart/druid/middleManager:/usr/local/imply-2.5.11/conf-quickstart/druid/_common:/usr/local/imply-2.5.11/bin/../dist/resources:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-dbcp2-2.0.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/airline-0.7.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/janino-2.7.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-dataformat-smile-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-codec-http-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-proxy-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-jaxrs-smile-provider-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-module-jaxb-annotations-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/java-xmlbuilder-1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/javax.servlet-api-3.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/RoaringBitmap-0.5.18.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/guice-4.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/curator-framework-4.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-indexing-hadoop-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-annotations-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-handler-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-mapper-asl-1.9.13.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jersey-server-1.19.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/reactive-streams-1.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/avatica-metrics-1.10.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/derbynet-10.11.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-buffer-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/irc-api-1.0-0014.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-io-2.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aether-connector-file-0.9.0.M2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-lang-2.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/compress-lzf-1.0.4.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-codec-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-io-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-sql-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/plexus-interpolation-1.19.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-http-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jsr311-api-1.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/asm-5.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/bcprov-jdk15on-1.52.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/classmate-1.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/protobuf-java-3.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-client-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-pool-1.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-processing-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maven-repository-metadata-3.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jersey-core-1.19.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/javax.el-api-3.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-jq-0.0.7.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-indexing-service-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/async-http-client-netty-utils-2.0.37.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jcl-over-slf4j-1.7.12.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/hibernate-validator-5.1.3.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/plexus-utils-3.0.15.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/javax.el-3.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jersey-guice-1.19.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-transport-native-epoll-4.0.52.Final-linux-x86_64.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/lz4-1.3.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/antlr4-runtime-4.5.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/guava-16.0.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/tesla-aether-0.0.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/extendedset-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/log4j-slf4j-impl-2.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/slf4j-api-1.6.4.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jdbi-2.63.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-common-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-cli-1.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-codec-1.7.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maven-model-3.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aether-impl-0.9.0.M2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maven-settings-builder-3.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/joda-time-2.9.9.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-jaxrs-json-provider-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/httpclient-4.5.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aether-connector-okhttp-0.0.9.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-api-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/esri-geometry-api-2.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/derbytools-10.11.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/curator-client-4.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/log4j-jul-2.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-servlet-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/zookeeper-3.4.10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-util-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/curator-recipes-4.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-resolver-2.0.37.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-core-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/activation-1.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-server-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-security-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-hll-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/log4j-core-2.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maven-settings-3.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-pool2-2.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jets3t-0.9.4.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jvm-attach-api-1.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/xz-1.8.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/fastutil-8.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/objenesis-2.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maven-model-builder-3.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/curator-x-discovery-4.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/config-magic-0.9.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jline-0.9.94.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/guice-servlet-4.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/disruptor-3.3.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/log4j-1.2-api-2.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/derbyclient-10.11.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-services-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-common-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/asm-tree-5.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-datatype-joda-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-jaxrs-base-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-continuation-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/icu4j-54.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/calcite-core-1.15.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-dbcp-1.4.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/javax.inject-1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-databind-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/avatica-server-1.10.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jersey-servlet-1.19.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-core-asl-1.9.13.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-compiler-2.7.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/validation-api-1.1.0.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/base64-2.3.8.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jboss-logging-3.1.3.GA.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-math3-3.6.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/rhino-1.7R5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aether-util-0.9.0.M2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-resolver-dns-2.0.37.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/joni-2.1.11.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/java-util-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aws-java-sdk-core-1.10.77.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/guice-multibindings-4.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-3.10.6.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/async-http-client-2.0.37.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-datatype-guava-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aopalliance-1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aws-java-sdk-ec2-1.10.77.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/opencsv-2.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aether-api-0.9.0.M2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aether-spi-0.9.0.M2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-logging-1.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aggdesigner-algorithm-6.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-server-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/avatica-core-1.10.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jcodings-1.0.13.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-aws-common-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/asm-commons-5.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-all-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/geoip2-0.4.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/wagon-provider-api-2.4.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/caffeine-2.5.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-console-0.0.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-dataformat-cbor-2.5.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-lang3-3.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/httpcore-4.4.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maven-aether-provider-3.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/log4j-api-2.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jsr305-2.0.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/derby-10.11.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-codec-dns-2.0.37.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-reactive-streams-1.0.8.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/mapdb-1.0.8.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maxminddb-0.2.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-compress-1.16.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/json-path-2.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-servlets-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-transport-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/spymemcached-2.12.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/calcite-linq4j-1.15.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/okhttp-1.0.2.jar -server -Xms512m -Xmx512m -XX:MaxDirectMemorySize=1g -Duser.timezone=UTC -Dfile.encoding=UTF-8 -Djava.util.logging.manager=org.apache.logging.log4j.jul.LogManager -Ddruid.indexer.task.baseTaskDir=var/druid/task -Ddruid.processing.buffer.sizeBytes=50000000 -Ddruid.metadata.storage.connector.password=risk_preprod@123 -Ddruid.emitter.logging.logLevel=debug -Ddruid.emitter=logging -Ddruid.indexer.task.restoreTasksOnRestart=true -Duser.timezone=UTC -Dfile.encoding.pkg=sun.io -Ddruid.storage.storageDirectory=/druid/segments -Ddruid.selectors.coordinator.serviceName=druid/coordinator -Ddruid.extensions.directory=dist/druid/extensions -Ddruid.selectors.indexing.serviceName=druid/overlord -Ddruid.lookup.enableLookupSyncOnStartup=false -Ddruid.port=8091 -Ddruid.server.http.numThreads=12 -Ddruid.worker.capacity=10 -Ddruid.extensions.hadoopDependenciesDir=dist/druid/hadoop-dependencies -Ddruid.processing.numMergeBuffers=2 -Ddruid.processing.tmpDir=var/druid/processing -Ddruid.service=druid/middlemanager -Ddruid.metadata.storage.connector.user=risk_preprod -Ddruid.metadata.storage.type=mysql -Ddruid.metadata.storage.connector.connectURI=jdbc:mysql://10.12.0.153:3306/druid_preprod -Djava.io.tmpdir=var/tmp -Ddruid.extensions.loadList=["druid-histogram", "druid-datasketches", "druid-kafka-indexing-service", "mysql-metadata-storage", "druid-hdfs-storage", "druid-parser-route", "druid-avro-extensions"] -Ddruid.sql.enable=true -Ddruid.startup.logging.logProperties=true -Ddruid.processing.numThreads=1 -Ddruid.zk.service.host=10.12.0.6:2184 -Dhadoop.hadoop.tmp.dir=var/hadoop-tmp -Ddruid.monitoring.monitors=["io.druid.java.util.metrics.JvmMonitor"] -Ddruid.indexer.logs.directory=/druid/indexing-logs -Ddruid.zk.paths.base=/druid -Dfile.encoding=UTF-8 -Ddruid.indexer.task.defaultHadoopCoordinates=["org.apache.hadoop:hadoop-client:2.7.3"] -Ddruid.storage.type=hdfs -Ddruid.indexer.task.hadoopWorkingPath=var/druid/hadoop-tmp -Ddruid.indexer.logs.type=hdfs -Ddruid.metrics.emitter.dimension.dataSource=preprod-market-decision-result-kafka -Ddruid.metrics.emitter.dimension.taskId=index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj -Ddruid.host=iZuf6flaph02htekc965qjZ -Ddruid.port=8104 -Ddruid.tlsPort=-1 io.druid.cli.Main internal peon var/druid/task/index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj/task.json var/druid/task/index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj/df87883b-4b83-4d0f-9aa6-bc22ed8fc6f0/status.json | |
| 2018-06-04T11:44:12,364 INFO [forking-task-runner-4] io.druid.indexing.overlord.TaskRunnerUtils - Task [index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj] location changed to [TaskLocation{host='iZuf6flaph02htekc965qjZ', port=8104, tlsPort=-1}]. | |
| 2018-06-04T11:44:12,364 INFO [forking-task-runner-4] io.druid.indexing.overlord.TaskRunnerUtils - Task [index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj] status changed to [RUNNING]. | |
| 2018-06-04T11:44:12,364 INFO [forking-task-runner-4] io.druid.indexing.overlord.ForkingTaskRunner - Logging task index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj output to: var/druid/task/index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj/log | |
| 2018-06-04T11:46:30,584 INFO [WorkerTaskManager-CompletedTasksCleaner] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8090 | |
| 2018-06-04T11:46:30,595 INFO [WorkerTaskManager-CompletedTasksCleaner] io.druid.indexing.worker.WorkerTaskManager - Deleting completed task[index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_bjoellcn] information, overlord task status[FAILED]. | |
| 2018-06-04T11:46:30,595 INFO [WorkerTaskManager-CompletedTasksCleaner] io.druid.indexing.worker.WorkerTaskManager - Deleting completed task[index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ghgdghfl] information, overlord task status[FAILED]. | |
| 2018-06-04T11:46:30,595 INFO [WorkerTaskManager-CompletedTasksCleaner] io.druid.indexing.worker.WorkerTaskManager - Deleting completed task[index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_bicnekon] information, overlord task status[FAILED]. | |
| 2018-06-04T11:46:30,595 INFO [WorkerTaskManager-CompletedTasksCleaner] io.druid.indexing.worker.WorkerTaskManager - Deleting completed task[index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_pdiebbnm] information, overlord task status[FAILED]. | |
| 2018-06-04T11:46:30,595 INFO [WorkerTaskManager-CompletedTasksCleaner] io.druid.indexing.worker.WorkerTaskManager - Deleting completed task[index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_kbmeemfo] information, overlord task status[FAILED]. | |
| 2018-06-04T12:13:12,472 INFO [qtp299684908-92] io.druid.indexing.overlord.ForkingTaskRunner - Killing process for task: index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk | |
| 2018-06-04T12:13:12,474 INFO [forking-task-runner-7] io.druid.storage.hdfs.tasklog.HdfsTaskLogs - Writing task log to: /druid/indexing-logs/index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk | |
| 2018-06-04T12:13:12,485 INFO [qtp299684908-97] io.druid.indexing.overlord.ForkingTaskRunner - Killing process for task: index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk | |
| 2018-06-04T12:13:12,496 INFO [qtp299684908-94] io.druid.indexing.overlord.ForkingTaskRunner - Killing process for task: index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk | |
| 2018-06-04T12:13:12,517 INFO [qtp299684908-83] io.druid.indexing.overlord.ForkingTaskRunner - Killing process for task: index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk | |
| 2018-06-04T12:13:12,519 INFO [forking-task-runner-7] io.druid.storage.hdfs.tasklog.HdfsTaskLogs - Wrote task log to: /druid/indexing-logs/index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk | |
| 2018-06-04T12:13:12,519 INFO [forking-task-runner-7] io.druid.indexing.overlord.ForkingTaskRunner - Exception caught during execution | |
| java.io.IOException: Stream closed | |
| at java.io.BufferedInputStream.getBufIfOpen(BufferedInputStream.java:170) ~[?:1.8.0_141] | |
| at java.io.BufferedInputStream.read1(BufferedInputStream.java:291) ~[?:1.8.0_141] | |
| at java.io.BufferedInputStream.read(BufferedInputStream.java:345) ~[?:1.8.0_141] | |
| at java.io.FilterInputStream.read(FilterInputStream.java:107) ~[?:1.8.0_141] | |
| at com.google.common.io.ByteStreams.copy(ByteStreams.java:175) ~[guava-16.0.1.jar:?] | |
| at io.druid.indexing.overlord.ForkingTaskRunner$1.call(ForkingTaskRunner.java:452) [druid-indexing-service-0.12.0-iap10.jar:0.12.0-iap10] | |
| at io.druid.indexing.overlord.ForkingTaskRunner$1.call(ForkingTaskRunner.java:224) [druid-indexing-service-0.12.0-iap10.jar:0.12.0-iap10] | |
| at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_141] | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_141] | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_141] | |
| at java.lang.Thread.run(Thread.java:748) [?:1.8.0_141] | |
| 2018-06-04T12:13:12,520 INFO [forking-task-runner-7] io.druid.indexing.overlord.ForkingTaskRunner - Removing task directory: var/druid/task/index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk | |
| 2018-06-04T12:13:12,526 INFO [WorkerTaskManager-NoticeHandler] io.druid.indexing.worker.WorkerTaskManager - Job's finished. Completed [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk] with status [FAILED] | |
| 2018-06-04T12:13:12,536 INFO [WorkerTaskManager-NoticeHandler] io.druid.indexing.worker.WorkerTaskManager - Task[index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea] started. | |
| 2018-06-04T12:13:12,538 INFO [forking-task-runner-8] io.druid.indexing.overlord.ForkingTaskRunner - Running command: java -cp /usr/local/imply-2.5.11/conf-quickstart/druid/middleManager:/usr/local/imply-2.5.11/conf-quickstart/druid/_common:/usr/local/imply-2.5.11/bin/../dist/resources:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-dbcp2-2.0.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/airline-0.7.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/janino-2.7.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-dataformat-smile-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-codec-http-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-proxy-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-jaxrs-smile-provider-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-module-jaxb-annotations-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/java-xmlbuilder-1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/javax.servlet-api-3.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/RoaringBitmap-0.5.18.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/guice-4.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/curator-framework-4.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-indexing-hadoop-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-annotations-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-handler-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-mapper-asl-1.9.13.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jersey-server-1.19.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/reactive-streams-1.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/avatica-metrics-1.10.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/derbynet-10.11.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-buffer-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/irc-api-1.0-0014.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-io-2.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aether-connector-file-0.9.0.M2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-lang-2.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/compress-lzf-1.0.4.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-codec-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-io-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-sql-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/plexus-interpolation-1.19.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-http-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jsr311-api-1.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/asm-5.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/bcprov-jdk15on-1.52.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/classmate-1.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/protobuf-java-3.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-client-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-pool-1.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-processing-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maven-repository-metadata-3.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jersey-core-1.19.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/javax.el-api-3.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-jq-0.0.7.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-indexing-service-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/async-http-client-netty-utils-2.0.37.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jcl-over-slf4j-1.7.12.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/hibernate-validator-5.1.3.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/plexus-utils-3.0.15.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/javax.el-3.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jersey-guice-1.19.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-transport-native-epoll-4.0.52.Final-linux-x86_64.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/lz4-1.3.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/antlr4-runtime-4.5.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/guava-16.0.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/tesla-aether-0.0.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/extendedset-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/log4j-slf4j-impl-2.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/slf4j-api-1.6.4.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jdbi-2.63.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-common-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-cli-1.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-codec-1.7.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maven-model-3.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aether-impl-0.9.0.M2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maven-settings-builder-3.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/joda-time-2.9.9.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-jaxrs-json-provider-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/httpclient-4.5.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aether-connector-okhttp-0.0.9.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-api-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/esri-geometry-api-2.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/derbytools-10.11.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/curator-client-4.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/log4j-jul-2.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-servlet-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/zookeeper-3.4.10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-util-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/curator-recipes-4.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-resolver-2.0.37.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-core-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/activation-1.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-server-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-security-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-hll-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/log4j-core-2.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maven-settings-3.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-pool2-2.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jets3t-0.9.4.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jvm-attach-api-1.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/xz-1.8.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/fastutil-8.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/objenesis-2.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maven-model-builder-3.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/curator-x-discovery-4.0.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/config-magic-0.9.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jline-0.9.94.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/guice-servlet-4.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/disruptor-3.3.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/log4j-1.2-api-2.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/derbyclient-10.11.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-services-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-common-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/asm-tree-5.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-datatype-joda-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-jaxrs-base-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-continuation-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/icu4j-54.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/calcite-core-1.15.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-dbcp-1.4.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/javax.inject-1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-databind-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/avatica-server-1.10.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jersey-servlet-1.19.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-core-asl-1.9.13.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-compiler-2.7.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/validation-api-1.1.0.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/base64-2.3.8.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jboss-logging-3.1.3.GA.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-math3-3.6.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/rhino-1.7R5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aether-util-0.9.0.M2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-resolver-dns-2.0.37.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/joni-2.1.11.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/java-util-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aws-java-sdk-core-1.10.77.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/guice-multibindings-4.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-3.10.6.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/async-http-client-2.0.37.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-datatype-guava-2.4.6.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aopalliance-1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aws-java-sdk-ec2-1.10.77.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/opencsv-2.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aether-api-0.9.0.M2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aether-spi-0.9.0.M2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-logging-1.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/aggdesigner-algorithm-6.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-server-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/avatica-core-1.10.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jcodings-1.0.13.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-aws-common-0.12.0-iap10.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/asm-commons-5.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-all-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/geoip2-0.4.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/wagon-provider-api-2.4.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/caffeine-2.5.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/druid-console-0.0.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jackson-dataformat-cbor-2.5.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-lang3-3.2.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/httpcore-4.4.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maven-aether-provider-3.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/log4j-api-2.5.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jsr305-2.0.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/derby-10.11.1.1.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-codec-dns-2.0.37.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-reactive-streams-1.0.8.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/mapdb-1.0.8.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/maxminddb-0.2.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/commons-compress-1.16.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/json-path-2.1.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/jetty-servlets-9.3.19.v20170502.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/netty-transport-4.0.52.Final.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/spymemcached-2.12.3.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/calcite-linq4j-1.15.0.jar:/usr/local/imply-2.5.11/bin/../dist/druid/lib/okhttp-1.0.2.jar -server -Xms512m -Xmx512m -XX:MaxDirectMemorySize=1g -Duser.timezone=UTC -Dfile.encoding=UTF-8 -Djava.util.logging.manager=org.apache.logging.log4j.jul.LogManager -Ddruid.indexer.task.baseTaskDir=var/druid/task -Ddruid.processing.buffer.sizeBytes=50000000 -Ddruid.metadata.storage.connector.password=risk_preprod@123 -Ddruid.emitter.logging.logLevel=debug -Ddruid.emitter=logging -Ddruid.indexer.task.restoreTasksOnRestart=true -Duser.timezone=UTC -Dfile.encoding.pkg=sun.io -Ddruid.storage.storageDirectory=/druid/segments -Ddruid.selectors.coordinator.serviceName=druid/coordinator -Ddruid.extensions.directory=dist/druid/extensions -Ddruid.selectors.indexing.serviceName=druid/overlord -Ddruid.lookup.enableLookupSyncOnStartup=false -Ddruid.port=8091 -Ddruid.server.http.numThreads=12 -Ddruid.worker.capacity=10 -Ddruid.extensions.hadoopDependenciesDir=dist/druid/hadoop-dependencies -Ddruid.processing.numMergeBuffers=2 -Ddruid.processing.tmpDir=var/druid/processing -Ddruid.service=druid/middlemanager -Ddruid.metadata.storage.connector.user=risk_preprod -Ddruid.metadata.storage.type=mysql -Ddruid.metadata.storage.connector.connectURI=jdbc:mysql://10.12.0.153:3306/druid_preprod -Djava.io.tmpdir=var/tmp -Ddruid.extensions.loadList=["druid-histogram", "druid-datasketches", "druid-kafka-indexing-service", "mysql-metadata-storage", "druid-hdfs-storage", "druid-parser-route", "druid-avro-extensions"] -Ddruid.sql.enable=true -Ddruid.startup.logging.logProperties=true -Ddruid.processing.numThreads=1 -Ddruid.zk.service.host=10.12.0.6:2184 -Dhadoop.hadoop.tmp.dir=var/hadoop-tmp -Ddruid.monitoring.monitors=["io.druid.java.util.metrics.JvmMonitor"] -Ddruid.indexer.logs.directory=/druid/indexing-logs -Ddruid.zk.paths.base=/druid -Dfile.encoding=UTF-8 -Ddruid.indexer.task.defaultHadoopCoordinates=["org.apache.hadoop:hadoop-client:2.7.3"] -Ddruid.storage.type=hdfs -Ddruid.indexer.task.hadoopWorkingPath=var/druid/hadoop-tmp -Ddruid.indexer.logs.type=hdfs -Ddruid.metrics.emitter.dimension.dataSource=preprod-risk-invocation-history-kafka -Ddruid.metrics.emitter.dimension.taskId=index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea -Ddruid.host=iZuf6flaph02htekc965qjZ -Ddruid.port=8103 -Ddruid.tlsPort=-1 io.druid.cli.Main internal peon var/druid/task/index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea/task.json var/druid/task/index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea/626c0fd7-4267-43e0-b5dc-8dab8e428cd2/status.json | |
| 2018-06-04T12:13:12,552 INFO [forking-task-runner-8] io.druid.indexing.overlord.TaskRunnerUtils - Task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea] location changed to [TaskLocation{host='iZuf6flaph02htekc965qjZ', port=8103, tlsPort=-1}]. | |
| 2018-06-04T12:13:12,552 INFO [forking-task-runner-8] io.druid.indexing.overlord.TaskRunnerUtils - Task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea] status changed to [RUNNING]. | |
| 2018-06-04T12:13:12,552 INFO [forking-task-runner-8] io.druid.indexing.overlord.ForkingTaskRunner - Logging task index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea output to: var/druid/task/index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea/log | |
| 2018-06-04T12:16:30,584 INFO [WorkerTaskManager-CompletedTasksCleaner] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://iZuf6flaph02htekc965qjZ:8090 | |
| 2018-06-04T12:16:30,590 INFO [WorkerTaskManager-CompletedTasksCleaner] io.druid.indexing.worker.WorkerTaskManager - Deleting completed task[index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_cgnlpdmk] information, overlord task status[FAILED]. | |
| 2018-06-04T12:24:31,775 INFO [Thread-24] io.druid.java.util.common.lifecycle.Lifecycle - Running shutdown hook | |
| 2018-06-04T12:24:31,783 INFO [Thread-24] io.druid.curator.discovery.CuratorDruidNodeAnnouncer - Unannouncing [DiscoveryDruidNode{druidNode=DruidNode{serviceName='druid/middlemanager', host='iZuf6flaph02htekc965qjZ', port=-1, plaintextPort=8091, enablePlaintextPort=true, tlsPort=-1, enableTlsPort=false}, nodeType='middleManager', services={workerNodeService=WorkerNodeService{ip='iZuf6flaph02htekc965qjZ', capacity=10, version='0'}}}]. | |
| 2018-06-04T12:24:31,783 INFO [Thread-24] io.druid.curator.announcement.Announcer - unannouncing [/druid/internal-discovery/middleManager/iZuf6flaph02htekc965qjZ:8091] | |
| 2018-06-04T12:24:31,791 INFO [Thread-24] io.druid.curator.discovery.CuratorDruidNodeAnnouncer - Unannounced [DiscoveryDruidNode{druidNode=DruidNode{serviceName='druid/middlemanager', host='iZuf6flaph02htekc965qjZ', port=-1, plaintextPort=8091, enablePlaintextPort=true, tlsPort=-1, enableTlsPort=false}, nodeType='middleManager', services={workerNodeService=WorkerNodeService{ip='iZuf6flaph02htekc965qjZ', capacity=10, version='0'}}}]. | |
| 2018-06-04T12:24:31,791 INFO [Thread-24] io.druid.server.initialization.jetty.JettyServerModule - Stopping Jetty Server... | |
| 2018-06-04T12:24:31,793 INFO [Thread-24] org.eclipse.jetty.server.AbstractConnector - Stopped ServerConnector@5c708288{HTTP/1.1,[http/1.1]}{0.0.0.0:8091} | |
| 2018-06-04T12:24:31,794 INFO [Thread-24] org.eclipse.jetty.server.handler.ContextHandler - Stopped o.e.j.s.ServletContextHandler@43deba42{/,null,UNAVAILABLE} | |
| 2018-06-04T12:24:31,799 INFO [Thread-24] io.druid.java.util.common.lifecycle.Lifecycle$AnnotationBasedHandler - Invoking stop method[public void io.druid.indexing.worker.WorkerTaskMonitor.stop() throws java.lang.Exception] on object[io.druid.indexing.worker.WorkerTaskMonitor@353f472a]. | |
| 2018-06-04T12:24:31,799 INFO [Thread-24] io.druid.indexing.overlord.ForkingTaskRunner - Unregistered listener [WorkerTaskManager] | |
| 2018-06-04T12:24:31,799 INFO [Thread-24] io.druid.indexing.overlord.ForkingTaskRunner - Closing output stream to task[index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch]. | |
| 2018-06-04T12:24:31,800 INFO [Thread-24] io.druid.indexing.overlord.ForkingTaskRunner - Closing output stream to task[index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn]. | |
| 2018-06-04T12:24:31,801 INFO [Thread-24] io.druid.indexing.overlord.ForkingTaskRunner - Closing output stream to task[index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii]. | |
| 2018-06-04T12:24:31,801 INFO [Thread-24] io.druid.indexing.overlord.ForkingTaskRunner - Closing output stream to task[index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj]. | |
| 2018-06-04T12:24:31,803 INFO [Thread-24] io.druid.indexing.overlord.ForkingTaskRunner - Closing output stream to task[index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea]. | |
| 2018-06-04T12:24:31,804 INFO [Thread-24] io.druid.indexing.overlord.ForkingTaskRunner - Closing output stream to task[index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch]. | |
| 2018-06-04T12:24:31,806 INFO [Thread-24] io.druid.indexing.overlord.ForkingTaskRunner - Waiting up to 300,000ms for shutdown. | |
| 2018-06-04T12:24:32,161 INFO [forking-task-runner-3-[index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch]] io.druid.indexing.overlord.ForkingTaskRunner - Process exited with status[2] for task: index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch | |
| 2018-06-04T12:24:32,161 INFO [forking-task-runner-3] io.druid.storage.hdfs.tasklog.HdfsTaskLogs - Writing task log to: /druid/indexing-logs/index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch | |
| 2018-06-04T12:24:32,175 INFO [forking-task-runner-8-[index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea]] io.druid.indexing.overlord.ForkingTaskRunner - Process exited with status[2] for task: index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea | |
| 2018-06-04T12:24:32,175 INFO [forking-task-runner-8] io.druid.storage.hdfs.tasklog.HdfsTaskLogs - Writing task log to: /druid/indexing-logs/index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea | |
| 2018-06-04T12:24:32,177 INFO [forking-task-runner-2-[index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn]] io.druid.indexing.overlord.ForkingTaskRunner - Process exited with status[2] for task: index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn | |
| 2018-06-04T12:24:32,177 INFO [forking-task-runner-2] io.druid.storage.hdfs.tasklog.HdfsTaskLogs - Writing task log to: /druid/indexing-logs/index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn | |
| 2018-06-04T12:24:32,211 INFO [forking-task-runner-4-[index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj]] io.druid.indexing.overlord.ForkingTaskRunner - Process exited with status[2] for task: index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj | |
| 2018-06-04T12:24:32,215 INFO [forking-task-runner-4] io.druid.storage.hdfs.tasklog.HdfsTaskLogs - Writing task log to: /druid/indexing-logs/index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj | |
| 2018-06-04T12:24:32,222 INFO [forking-task-runner-0-[index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch]] io.druid.indexing.overlord.ForkingTaskRunner - Process exited with status[2] for task: index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch | |
| 2018-06-04T12:24:32,222 INFO [forking-task-runner-0] io.druid.storage.hdfs.tasklog.HdfsTaskLogs - Writing task log to: /druid/indexing-logs/index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch | |
| 2018-06-04T12:24:32,244 INFO [forking-task-runner-8] io.druid.storage.hdfs.tasklog.HdfsTaskLogs - Wrote task log to: /druid/indexing-logs/index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea | |
| 2018-06-04T12:24:32,244 INFO [forking-task-runner-8] io.druid.indexing.overlord.TaskRunnerUtils - Task [index_kafka_preprod-risk-invocation-history-kafka_652901e4170eb5c_icpcpjea] status changed to [FAILED]. | |
| 2018-06-04T12:24:32,245 INFO [forking-task-runner-2] io.druid.storage.hdfs.tasklog.HdfsTaskLogs - Wrote task log to: /druid/indexing-logs/index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn | |
| 2018-06-04T12:24:32,245 INFO [forking-task-runner-2] io.druid.indexing.overlord.TaskRunnerUtils - Task [index_kafka_preprod-credit-invocation-history-kafka_878476204eaf5db_ipolkfmn] status changed to [FAILED]. | |
| 2018-06-04T12:24:32,245 ERROR [forking-task-runner-2] com.google.common.util.concurrent.ExecutionList - RuntimeException while executing runnable com.google.common.util.concurrent.Futures$4@76f09423 with executor com.google.common.util.concurrent.MoreExecutors$SameThreadExecutorService@52faebf3 | |
| java.util.concurrent.RejectedExecutionException: Task io.druid.indexing.worker.WorkerTaskManager$$Lambda$37/434889755@5e95e213 rejected from java.util.concurrent.ThreadPoolExecutor@21c5d460[Terminated, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 129] | |
| at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2063) ~[?:1.8.0_141] | |
| at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:830) ~[?:1.8.0_141] | |
| at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1379) ~[?:1.8.0_141] | |
| at java.util.concurrent.Executors$DelegatedExecutorService.execute(Executors.java:668) ~[?:1.8.0_141] | |
| at io.druid.indexing.worker.WorkerTaskManager.submitNoticeToExec(WorkerTaskManager.java:179) ~[druid-indexing-service-0.12.0-iap10.jar:0.12.0-iap10] | |
| at io.druid.indexing.worker.WorkerTaskManager.access$000(WorkerTaskManager.java:77) ~[druid-indexing-service-0.12.0-iap10.jar:0.12.0-iap10] | |
| at io.druid.indexing.worker.WorkerTaskManager$2.onSuccess(WorkerTaskManager.java:243) ~[druid-indexing-service-0.12.0-iap10.jar:0.12.0-iap10] | |
| at io.druid.indexing.worker.WorkerTaskManager$2.onSuccess(WorkerTaskManager.java:239) ~[druid-indexing-service-0.12.0-iap10.jar:0.12.0-iap10] | |
| 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_141] | |
| at java.util.concurrent.FutureTask.set(FutureTask.java:233) [?:1.8.0_141] | |
| at java.util.concurrent.FutureTask.run(FutureTask.java:274) [?:1.8.0_141] | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_141] | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_141] | |
| at java.lang.Thread.run(Thread.java:748) [?:1.8.0_141] | |
| 2018-06-04T12:24:32,245 INFO [forking-task-runner-0] io.druid.storage.hdfs.tasklog.HdfsTaskLogs - Wrote task log to: /druid/indexing-logs/index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch | |
| 2018-06-04T12:24:32,245 INFO [forking-task-runner-0] io.druid.indexing.overlord.TaskRunnerUtils - Task [index_kafka_preprod-loanend-event-cancel-plan-repayment-kafka_07f65c8b7bb5424_kgfeflch] status changed to [FAILED]. | |
| 2018-06-04T12:24:32,244 ERROR [forking-task-runner-8] com.google.common.util.concurrent.ExecutionList - RuntimeException while executing runnable com.google.common.util.concurrent.Futures$4@6cf717c1 with executor com.google.common.util.concurrent.MoreExecutors$SameThreadExecutorService@1f5b56e3 | |
| java.util.concurrent.RejectedExecutionException: Task io.druid.indexing.worker.WorkerTaskManager$$Lambda$37/434889755@3980bd1a rejected from java.util.concurrent.ThreadPoolExecutor@21c5d460[Terminated, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 129] | |
| at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2063) ~[?:1.8.0_141] | |
| at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:830) ~[?:1.8.0_141] | |
| at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1379) ~[?:1.8.0_141] | |
| at java.util.concurrent.Executors$DelegatedExecutorService.execute(Executors.java:668) ~[?:1.8.0_141] | |
| at io.druid.indexing.worker.WorkerTaskManager.submitNoticeToExec(WorkerTaskManager.java:179) ~[druid-indexing-service-0.12.0-iap10.jar:0.12.0-iap10] | |
| at io.druid.indexing.worker.WorkerTaskManager.access$000(WorkerTaskManager.java:77) ~[druid-indexing-service-0.12.0-iap10.jar:0.12.0-iap10] | |
| at io.druid.indexing.worker.WorkerTaskManager$2.onSuccess(WorkerTaskManager.java:243) ~[druid-indexing-service-0.12.0-iap10.jar:0.12.0-iap10] | |
| at io.druid.indexing.worker.WorkerTaskManager$2.onSuccess(WorkerTaskManager.java:239) ~[druid-indexing-service-0.12.0-iap10.jar:0.12.0-iap10] | |
| 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_141] | |
| at java.util.concurrent.FutureTask.set(FutureTask.java:233) [?:1.8.0_141] | |
| at java.util.concurrent.FutureTask.run(FutureTask.java:274) [?:1.8.0_141] | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_141] | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_141] | |
| at java.lang.Thread.run(Thread.java:748) [?:1.8.0_141] | |
| 2018-06-04T12:24:32,247 INFO [forking-task-runner-4] io.druid.storage.hdfs.tasklog.HdfsTaskLogs - Wrote task log to: /druid/indexing-logs/index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj | |
| 2018-06-04T12:24:32,247 INFO [forking-task-runner-4] io.druid.indexing.overlord.TaskRunnerUtils - Task [index_kafka_preprod-market-decision-result-kafka_f2a2a794c5f012a_defgjhgj] status changed to [FAILED]. | |
| 2018-06-04T12:24:32,247 ERROR [forking-task-runner-0] com.google.common.util.concurrent.ExecutionList - RuntimeException while executing runnable com.google.common.util.concurrent.Futures$4@71a0a9d0 with executor com.google.common.util.concurrent.MoreExecutors$SameThreadExecutorService@23c5a188 | |
| java.util.concurrent.RejectedExecutionException: Task io.druid.indexing.worker.WorkerTaskManager$$Lambda$37/434889755@281e7785 rejected from java.util.concurrent.ThreadPoolExecutor@21c5d460[Terminated, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 129] | |
| at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2063) ~[?:1.8.0_141] | |
| at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:830) ~[?:1.8.0_141] | |
| at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1379) ~[?:1.8.0_141] | |
| at java.util.concurrent.Executors$DelegatedExecutorService.execute(Executors.java:668) ~[?:1.8.0_141] | |
| at io.druid.indexing.worker.WorkerTaskManager.submitNoticeToExec(WorkerTaskManager.java:179) ~[druid-indexing-service-0.12.0-iap10.jar:0.12.0-iap10] | |
| at io.druid.indexing.worker.WorkerTaskManager.access$000(WorkerTaskManager.java:77) ~[druid-indexing-service-0.12.0-iap10.jar:0.12.0-iap10] | |
| at io.druid.indexing.worker.WorkerTaskManager$2.onSuccess(WorkerTaskManager.java:243) ~[druid-indexing-service-0.12.0-iap10.jar:0.12.0-iap10] | |
| at io.druid.indexing.worker.WorkerTaskManager$2.onSuccess(WorkerTaskManager.java:239) ~[druid-indexing-service-0.12.0-iap10.jar:0.12.0-iap10] | |
| 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_141] | |
| at java.util.concurrent.FutureTask.set(FutureTask.java:233) [?:1.8.0_141] | |
| at java.util.concurrent.FutureTask.run(FutureTask.java:274) [?:1.8.0_141] | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_141] | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_141] | |
| at java.lang.Thread.run(Thread.java:748) [?:1.8.0_141] | |
| 2018-06-04T12:24:32,247 ERROR [forking-task-runner-4] com.google.common.util.concurrent.ExecutionList - RuntimeException while executing runnable com.google.common.util.concurrent.Futures$4@723a1972 with executor com.google.common.util.concurrent.MoreExecutors$SameThreadExecutorService@694e2550 | |
| java.util.concurrent.RejectedExecutionException: Task io.druid.indexing.worker.WorkerTaskManager$$Lambda$37/434889755@3a5af666 rejected from java.util.concurrent.ThreadPoolExecutor@21c5d460[Terminated, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 129] | |
| at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2063) ~[?:1.8.0_141] | |
| at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:830) ~[?:1.8.0_141] | |
| at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1379) ~[?:1.8.0_141] | |
| at java.util.concurrent.Executors$DelegatedExecutorService.execute(Executors.java:668) ~[?:1.8.0_141] | |
| at io.druid.indexing.worker.WorkerTaskManager.submitNoticeToExec(WorkerTaskManager.java:179) ~[druid-indexing-service-0.12.0-iap10.jar:0.12.0-iap10] | |
| at io.druid.indexing.worker.WorkerTaskManager.access$000(WorkerTaskManager.java:77) ~[druid-indexing-service-0.12.0-iap10.jar:0.12.0-iap10] | |
| at io.druid.indexing.worker.WorkerTaskManager$2.onSuccess(WorkerTaskManager.java:243) ~[druid-indexing-service-0.12.0-iap10.jar:0.12.0-iap10] | |
| at io.druid.indexing.worker.WorkerTaskManager$2.onSuccess(WorkerTaskManager.java:239) ~[druid-indexing-service-0.12.0-iap10.jar:0.12.0-iap10] | |
| 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_141] | |
| at java.util.concurrent.FutureTask.set(FutureTask.java:233) [?:1.8.0_141] | |
| at java.util.concurrent.FutureTask.run(FutureTask.java:274) [?:1.8.0_141] | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_141] | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_141] | |
| at java.lang.Thread.run(Thread.java:748) [?:1.8.0_141] | |
| 2018-06-04T12:24:32,250 INFO [forking-task-runner-3] io.druid.storage.hdfs.tasklog.HdfsTaskLogs - Wrote task log to: /druid/indexing-logs/index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch | |
| 2018-06-04T12:24:32,250 INFO [forking-task-runner-3] io.druid.indexing.overlord.TaskRunnerUtils - Task [index_kafka_preprod-payment-event-plan-repayment-kafka_435cfbeac3e05ee_bgcabhch] status changed to [FAILED]. | |
| 2018-06-04T12:24:32,251 ERROR [forking-task-runner-3] com.google.common.util.concurrent.ExecutionList - RuntimeException while executing runnable com.google.common.util.concurrent.Futures$4@67fb66c8 with executor com.google.common.util.concurrent.MoreExecutors$SameThreadExecutorService@1bfccaf8 | |
| java.util.concurrent.RejectedExecutionException: Task io.druid.indexing.worker.WorkerTaskManager$$Lambda$37/434889755@17c0cef0 rejected from java.util.concurrent.ThreadPoolExecutor@21c5d460[Terminated, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 129] | |
| at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2063) ~[?:1.8.0_141] | |
| at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:830) ~[?:1.8.0_141] | |
| at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1379) ~[?:1.8.0_141] | |
| at java.util.concurrent.Executors$DelegatedExecutorService.execute(Executors.java:668) ~[?:1.8.0_141] | |
| at io.druid.indexing.worker.WorkerTaskManager.submitNoticeToExec(WorkerTaskManager.java:179) ~[druid-indexing-service-0.12.0-iap10.jar:0.12.0-iap10] | |
| at io.druid.indexing.worker.WorkerTaskManager.access$000(WorkerTaskManager.java:77) ~[druid-indexing-service-0.12.0-iap10.jar:0.12.0-iap10] | |
| at io.druid.indexing.worker.WorkerTaskManager$2.onSuccess(WorkerTaskManager.java:243) ~[druid-indexing-service-0.12.0-iap10.jar:0.12.0-iap10] | |
| at io.druid.indexing.worker.WorkerTaskManager$2.onSuccess(WorkerTaskManager.java:239) ~[druid-indexing-service-0.12.0-iap10.jar:0.12.0-iap10] | |
| 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_141] | |
| at java.util.concurrent.FutureTask.set(FutureTask.java:233) [?:1.8.0_141] | |
| at java.util.concurrent.FutureTask.run(FutureTask.java:274) [?:1.8.0_141] | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_141] | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_141] | |
| at java.lang.Thread.run(Thread.java:748) [?:1.8.0_141] | |
| 2018-06-04T12:24:32,254 INFO [forking-task-runner-5-[index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii]] io.druid.indexing.overlord.ForkingTaskRunner - Process exited with status[2] for task: index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii | |
| 2018-06-04T12:24:32,254 INFO [forking-task-runner-5] io.druid.storage.hdfs.tasklog.HdfsTaskLogs - Writing task log to: /druid/indexing-logs/index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii | |
| 2018-06-04T12:24:32,264 INFO [forking-task-runner-5] io.druid.storage.hdfs.tasklog.HdfsTaskLogs - Wrote task log to: /druid/indexing-logs/index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii | |
| 2018-06-04T12:24:32,264 INFO [forking-task-runner-5] io.druid.indexing.overlord.TaskRunnerUtils - Task [index_kafka_preprod-overdue-event-kafka_9c9f3f6a717cb1e_addfgpii] status changed to [FAILED]. | |
| 2018-06-04T12:24:32,264 ERROR [forking-task-runner-5] com.google.common.util.concurrent.ExecutionList - RuntimeException while executing runnable com.google.common.util.concurrent.Futures$4@39bcf286 with executor com.google.common.util.concurrent.MoreExecutors$SameThreadExecutorService@520a5656 | |
| java.util.concurrent.RejectedExecutionException: Task io.druid.indexing.worker.WorkerTaskManager$$Lambda$37/434889755@5467f341 rejected from java.util.concurrent.ThreadPoolExecutor@21c5d460[Terminated, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 129] | |
| at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2063) ~[?:1.8.0_141] | |
| at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:830) ~[?:1.8.0_141] | |
| at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1379) ~[?:1.8.0_141] | |
| at java.util.concurrent.Executors$DelegatedExecutorService.execute(Executors.java:668) ~[?:1.8.0_141] | |
| at io.druid.indexing.worker.WorkerTaskManager.submitNoticeToExec(WorkerTaskManager.java:179) ~[druid-indexing-service-0.12.0-iap10.jar:0.12.0-iap10] | |
| at io.druid.indexing.worker.WorkerTaskManager.access$000(WorkerTaskManager.java:77) ~[druid-indexing-service-0.12.0-iap10.jar:0.12.0-iap10] | |
| at io.druid.indexing.worker.WorkerTaskManager$2.onSuccess(WorkerTaskManager.java:243) ~[druid-indexing-service-0.12.0-iap10.jar:0.12.0-iap10] | |
| at io.druid.indexing.worker.WorkerTaskManager$2.onSuccess(WorkerTaskManager.java:239) ~[druid-indexing-service-0.12.0-iap10.jar:0.12.0-iap10] | |
| 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_141] | |
| at java.util.concurrent.FutureTask.set(FutureTask.java:233) [?:1.8.0_141] | |
| at java.util.concurrent.FutureTask.run(FutureTask.java:274) [?:1.8.0_141] | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_141] | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_141] | |
| at java.lang.Thread.run(Thread.java:748) [?:1.8.0_141] | |
| 2018-06-04T12:24:32,265 INFO [Thread-24] io.druid.indexing.overlord.ForkingTaskRunner - Finished stopping in 460ms. | |
| 2018-06-04T12:24:32,265 INFO [Thread-24] io.druid.indexing.worker.WorkerTaskManager - Stopped WorkerTaskManager. | |
| 2018-06-04T12:24:32,265 INFO [Thread-24] io.druid.indexing.worker.WorkerTaskMonitor - Stopped WorkerTaskMonitor. | |
| 2018-06-04T12:24:32,265 INFO [Thread-24] io.druid.java.util.common.lifecycle.Lifecycle$AnnotationBasedHandler - Invoking stop method[public void io.druid.discovery.DruidLeaderClient.stop()] on object[io.druid.discovery.DruidLeaderClient@385d819]. | |
| 2018-06-04T12:24:32,265 INFO [Thread-24] io.druid.discovery.DruidLeaderClient - Stopped. | |
| 2018-06-04T12:24:32,265 INFO [Thread-24] io.druid.java.util.common.lifecycle.Lifecycle$AnnotationBasedHandler - Invoking stop method[public void io.druid.curator.discovery.ServerDiscoverySelector.stop() throws java.io.IOException] on object[io.druid.curator.discovery.ServerDiscoverySelector@e5c2463]. | |
| 2018-06-04T12:24:32,267 INFO [Thread-24] io.druid.java.util.common.lifecycle.Lifecycle$AnnotationBasedHandler - Invoking stop method[public void io.druid.curator.discovery.CuratorDruidNodeDiscoveryProvider.stop()] on object[io.druid.curator.discovery.CuratorDruidNodeDiscoveryProvider@87d9a01]. | |
| 2018-06-04T12:24:32,267 INFO [Thread-24] io.druid.curator.discovery.CuratorDruidNodeDiscoveryProvider - stopping | |
| 2018-06-04T12:24:32,267 INFO [Thread-24] io.druid.curator.discovery.CuratorDruidNodeDiscoveryProvider - stopped | |
| 2018-06-04T12:24:32,267 INFO [Thread-24] io.druid.java.util.common.lifecycle.Lifecycle$AnnotationBasedHandler - Invoking stop method[public void io.druid.java.util.http.client.NettyHttpClient.stop()] on object[io.druid.java.util.http.client.NettyHttpClient@2eb60c71]. | |
| 2018-06-04T12:24:32,277 INFO [Thread-24] io.druid.java.util.common.lifecycle.Lifecycle$AnnotationBasedHandler - Invoking stop method[public void io.druid.indexing.worker.WorkerCuratorCoordinator.stop() throws java.lang.Exception] on object[io.druid.indexing.worker.WorkerCuratorCoordinator@52f6900a]. | |
| 2018-06-04T12:24:32,277 INFO [Thread-24] io.druid.indexing.worker.WorkerCuratorCoordinator - Stopping WorkerCuratorCoordinator for worker[iZuf6flaph02htekc965qjZ:8091] | |
| 2018-06-04T12:24:32,277 INFO [Thread-24] io.druid.curator.announcement.Announcer - Stopping announcer | |
| 2018-06-04T12:24:32,279 INFO [Thread-24] io.druid.curator.announcement.Announcer - unannouncing [/druid/indexer/announcements/iZuf6flaph02htekc965qjZ:8091] | |
| 2018-06-04T12:24:32,280 INFO [Thread-24] io.druid.java.util.common.lifecycle.Lifecycle$AnnotationBasedHandler - Invoking stop method[public void io.druid.storage.hdfs.HdfsStorageAuthentication.stop()] on object[io.druid.storage.hdfs.HdfsStorageAuthentication@23ca36d]. | |
| 2018-06-04T12:24:32,280 INFO [Thread-24] io.druid.java.util.common.lifecycle.Lifecycle$AnnotationBasedHandler - Invoking stop method[public void io.druid.java.util.metrics.MonitorScheduler.stop()] on object[io.druid.java.util.metrics.MonitorScheduler@47a7c93e]. | |
| 2018-06-04T12:24:32,281 INFO [Thread-24] io.druid.java.util.common.lifecycle.Lifecycle$AnnotationBasedHandler - Invoking stop method[public void io.druid.java.util.emitter.service.ServiceEmitter.close() throws java.io.IOException] on object[ServiceEmitter{serviceDimensions={service=druid/middlemanager, host=iZuf6flaph02htekc965qjZ:8091, version=0.12.0-iap10}, emitter=LoggingEmitter{log=Logger{name=[io.druid.java.util.emitter.core.LoggingEmitter], class[class org.apache.logging.slf4j.Log4jLogger]}, level=DEBUG}}]. | |
| 2018-06-04T12:24:32,281 INFO [Thread-24] io.druid.java.util.common.lifecycle.Lifecycle$AnnotationBasedHandler - Invoking stop method[public void io.druid.initialization.Log4jShutterDownerModule$Log4jShutterDowner.stop()] on object[io.druid.initialization.Log4jShutterDownerModule$Log4jShutterDowner@7bee8621]. |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment