2021-05-10T12:39:11,119 INFO [main] org.hibernate.validator.internal.util.Version - HV000001: Hibernate Validator 5.2.5.Final
2021-05-10T12:39:12,574 INFO [main] org.apache.druid.initialization.Initialization - Loading extension [druid-datasketches], jars: druid-datasketches-0.20.1.jar, commons-math3-3.6.1.jar
2021-05-10T12:39:12,581 INFO [main] org.apache.druid.initialization.Initialization - Loading extension [druid-kafka-indexing-service], jars: lz4-java-1.7.1.jar, snappy-java-1.1.7.3.jar, kafka-clients-2.6.0.jar, druid-kafka-indexing-service-0.20.1.jar, zstd-jni-1.3.3-1.jar
2021-05-10T12:39:12,589 INFO [main] org.apache.druid.initialization.Initialization - Loading extension [postgresql-metadata-storage], jars: postgresql-metadata-storage-0.20.1.jar, postgresql-42.2.14.jar
2021-05-10T12:39:12,591 INFO [main] org.apache.druid.initialization.Initialization - Loading extension [druid-lookups-cached-global], jars: mapdb-1.0.8.jar, druid-lookups-cached-global-0.20.1.jar, postgresql-42.2.14.jar
2021-05-10T12:39:12,594 INFO [main] org.apache.druid.initialization.Initialization - Loading extension [druid-histogram], jars: druid-histogram-0.20.1.jar
2021-05-10T12:39:12,596 INFO [main] org.apache.druid.initialization.Initialization - Loading extension [druid-time-min-max], jars: druid-time-min-max-0.20.1.jar
2021-05-10T12:39:12,598 INFO [main] org.apache.druid.initialization.Initialization - Loading extension [druid-basic-security], jars: druid-basic-security-0.20.1.jar
2021-05-10T12:39:13,167 INFO [main] org.apache.druid.initialization.Initialization - Loading extension [druid-datasketches], jars: druid-datasketches-0.20.1.jar, commons-math3-3.6.1.jar
2021-05-10T12:39:13,222 INFO [main] org.apache.druid.initialization.Initialization - Loading extension [druid-kafka-indexing-service], jars: lz4-java-1.7.1.jar, snappy-java-1.1.7.3.jar, kafka-clients-2.6.0.jar, druid-kafka-indexing-service-0.20.1.jar, zstd-jni-1.3.3-1.jar
2021-05-10T12:39:13,226 INFO [main] org.apache.druid.initialization.Initialization - Loading extension [postgresql-metadata-storage], jars: postgresql-metadata-storage-0.20.1.jar, postgresql-42.2.14.jar
2021-05-10T12:39:13,228 INFO [main] org.apache.druid.initialization.Initialization - Loading extension [druid-lookups-cached-global], jars: mapdb-1.0.8.jar, druid-lookups-cached-global-0.20.1.jar, postgresql-42.2.14.jar
2021-05-10T12:39:13,234 INFO [main] org.apache.druid.initialization.Initialization - Loading extension [druid-histogram], jars: druid-histogram-0.20.1.jar
2021-05-10T12:39:13,246 INFO [main] org.apache.druid.initialization.Initialization - Loading extension [druid-time-min-max], jars: druid-time-min-max-0.20.1.jar
2021-05-10T12:39:13,250 INFO [main] org.apache.druid.initialization.Initialization - Loading extension [druid-basic-security], jars: druid-basic-security-0.20.1.jar
2021-05-10T12:39:20,209 INFO [main] org.apache.curator.utils.Compatibility - Running in ZooKeeper 3.4.x compatibility mode
2021-05-10T12:39:20,213 INFO [main] org.apache.curator.utils.Compatibility - Using emulated InjectSessionExpiration
2021-05-10T12:39:20,352 INFO [main] org.apache.druid.guice.JsonConfigurator - Skipping druid.emitter.http.recipientBaseUrl property: one of it's prefixes is also used as a property key. Prefix: druid
2021-05-10T12:39:20,549 INFO [main] org.apache.druid.server.emitter.EmitterModule - Using emitter [HttpPostEmitter{config=HttpEmitterConfig{flushMillis=60000, flushCount=500, flushTimeOut=9223372036854775807, basicAuthentication='null', batchingStrategy=ARRAY, maxBatchSize=5242880, contentEncoding=null, batchQueueSizeLimit=36, httpTimeoutAllowanceFactor=2.0, minHttpTimeoutMillis=0, recipientBaseUrl='http://druid_exporter:8080/druid'}}] for metrics and alerts, with dimensions [{version=0.20.1}].
2021-05-10T12:39:21,749 INFO [main] org.apache.druid.java.util.metrics.SigarUtil - Loading sigar native lib at tmpPath[var/tmp/sigar6964698660230461479/libsigar-amd64-linux.so]
2021-05-10T12:39:22,179 INFO [main] org.apache.druid.server.metrics.MetricsModule - Loaded 6 monitors: org.apache.druid.java.util.metrics.SysMonitor, org.apache.druid.java.util.metrics.JvmMonitor, org.apache.druid.client.cache.CacheMonitor, org.apache.druid.java.util.metrics.JvmThreadsMonitor, org.apache.druid.query.ExecutorServiceMonitor, org.apache.druid.server.initialization.jetty.JettyServerModule$JettyMonitor
2021-05-10T12:39:22,187 INFO [main] org.apache.druid.cli.CliPeon - Starting up with processors[4], memory[1,105,199,104], maxMemory[1,908,932,608], directMemory[2,147,483,648]. Properties follow.
2021-05-10T12:39:23,075 INFO [main] org.skife.config.ConfigurationObjectFactory - Using method itself for [druid.computation.buffer.poolCacheMaxCount, ${base_path}.buffer.poolCacheMaxCount] on [org.apache.druid.query.DruidProcessingConfig#poolCacheMaxCount()]
2021-05-10T12:39:23,078 INFO [main] org.skife.config.ConfigurationObjectFactory - Using method itself for [${base_path}.merge.pool.awaitShutdownMillis] on [org.apache.druid.query.DruidProcessingConfig#getMergePoolAwaitShutdownMillis()]
2021-05-10T12:39:23,078 INFO [main] org.skife.config.ConfigurationObjectFactory - Assigning value [100000000] for [druid.processing.buffer.sizeBytes] on [org.apache.druid.query.DruidProcessingConfig#intermediateComputeSizeBytesConfigured()]
2021-05-10T12:39:23,079 INFO [main] org.skife.config.ConfigurationObjectFactory - Using method itself for [${base_path}.numThreads] on [org.apache.druid.query.DruidProcessingConfig#getNumThreadsConfigured()]
2021-05-10T12:39:23,080 INFO [main] org.skife.config.ConfigurationObjectFactory - Assigning value [2] for [druid.processing.numMergeBuffers] on [org.apache.druid.query.DruidProcessingConfig#getNumMergeBuffersConfigured()]
2021-05-10T12:39:23,080 INFO [main] org.skife.config.ConfigurationObjectFactory - Using method itself for [${base_path}.columnCache.sizeBytes] on [org.apache.druid.query.DruidProcessingConfig#columnCacheSizeBytes()]
2021-05-10T12:39:23,080 INFO [main] org.skife.config.ConfigurationObjectFactory - Using method itself for [${base_path}.fifo] on [org.apache.druid.query.DruidProcessingConfig#isFifo()]
2021-05-10T12:39:23,080 INFO [main] org.skife.config.ConfigurationObjectFactory - Using method itself for [${base_path}.tmpDir] on [org.apache.druid.query.DruidProcessingConfig#getTmpDir()]
2021-05-10T12:39:23,081 INFO [main] org.skife.config.ConfigurationObjectFactory - Using method itself for [${base_path}.merge.useParallelMergePool] on [org.apache.druid.query.DruidProcessingConfig#useParallelMergePoolConfigured()]
2021-05-10T12:39:23,081 INFO [main] org.skife.config.ConfigurationObjectFactory - Using method itself for [${base_path}.merge.pool.parallelism] on [org.apache.druid.query.DruidProcessingConfig#getMergePoolParallelismConfigured()]
2021-05-10T12:39:23,081 INFO [main] org.skife.config.ConfigurationObjectFactory - Using method itself for [${base_path}.merge.pool.defaultMaxQueryParallelism] on [org.apache.druid.query.DruidProcessingConfig#getMergePoolDefaultMaxQueryParallelism()]
2021-05-10T12:39:23,081 INFO [main] org.skife.config.ConfigurationObjectFactory - Using method itself for [${base_path}.merge.task.targetRunTimeMillis] on [org.apache.druid.query.DruidProcessingConfig#getMergePoolTargetTaskRunTimeMillis()]
2021-05-10T12:39:23,082 INFO [main] org.skife.config.ConfigurationObjectFactory - Using method itself for [${base_path}.merge.task.initialYieldNumRows] on [org.apache.druid.query.DruidProcessingConfig#getMergePoolTaskInitialYieldRows()]
2021-05-10T12:39:23,082 INFO [main] org.skife.config.ConfigurationObjectFactory - Using method itself for [${base_path}.merge.task.smallBatchNumRows] on [org.apache.druid.query.DruidProcessingConfig#getMergePoolSmallBatchRows()]
2021-05-10T12:39:23,082 INFO [main] org.skife.config.ConfigurationObjectFactory - Assigning default value [processing-%s] for [${base_path}.formatString] on [org.apache.druid.java.util.common.concurrent.ExecutorServiceConfig#getFormatString()]
2021-05-10T12:39:23,360 INFO [main] org.apache.druid.guice.StorageNodeModule - Segment cache not configured on ServerType [indexer-executor]. It will not be assignable for segment placement
2021-05-10T12:39:23,842 INFO [main] org.eclipse.jetty.util.log - Logging initialized @15047ms to org.eclipse.jetty.util.log.Slf4jLog
2021-05-10T12:39:23,889 INFO [main] org.apache.druid.server.initialization.jetty.JettyServerModule - Creating http connector with port [8100]
2021-05-10T12:39:24,173 WARN [main] org.eclipse.jetty.server.handler.gzip.GzipHandler - minGzipSize of 0 is inefficient for short content, break even is size 23
2021-05-10T12:39:24,201 INFO [main] org.apache.druid.offheap.OffheapBufferGenerator - Allocating new intermediate processing buffer[0] of size[100,000,000]
2021-05-10T12:39:24,310 INFO [main] org.apache.druid.offheap.OffheapBufferGenerator - Allocating new intermediate processing buffer[1] of size[100,000,000]
2021-05-10T12:39:24,414 INFO [main] org.apache.druid.offheap.OffheapBufferGenerator - Allocating new intermediate processing buffer[2] of size[100,000,000]
2021-05-10T12:39:24,608 INFO [main] org.apache.druid.offheap.OffheapBufferGenerator - Allocating new result merging buffer[0] of size[100,000,000]
2021-05-10T12:39:24,699 INFO [main] org.apache.druid.offheap.OffheapBufferGenerator - Allocating new result merging buffer[1] of size[100,000,000]
2021-05-10T12:39:24,856 INFO [main] org.apache.druid.java.util.common.lifecycle.Lifecycle - Starting lifecycle [module] stage [INIT]
2021-05-10T12:39:24,861 INFO [main] org.apache.druid.java.util.common.lifecycle.Lifecycle - Starting lifecycle [module] stage [NORMAL]
2021-05-10T12:39:24,869 INFO [main] org.apache.curator.framework.imps.CuratorFrameworkImpl - Starting
2021-05-10T12:39:24,887 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:zookeeper.version=3.4.14-4c25d480e66aadd371de8bd2fd8da255ac140bcf, built on 03/06/2019 16:18 GMT
2021-05-10T12:39:24,887 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:host.name=23bfaec7cc1e
2021-05-10T12:39:24,887 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:java.version=1.8.0_275
2021-05-10T12:39:24,887 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:java.vendor=Oracle Corporation
2021-05-10T12:39:24,887 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:java.home=/usr/lib/jvm/java-8-openjdk-amd64/jre
2021-05-10T12:39:24,887 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:java.class.path=/tmp/conf/druid/cluster/_common:/tmp/conf/druid/cluster/data/middleManager:lib/jackson-datatype-joda-2.10.2.jar:lib/reactive-streams-1.0.2.jar:lib/async-http-client-netty-utils-2.5.3.jar:lib/disruptor-3.3.6.jar:lib/commons-lang-2.6.jar:lib/fastutil-8.2.3.jar:lib/guice-multibindings-4.1.0.jar:lib/google-api-client-1.26.0.jar:lib/javax.inject-1.jar:lib/resilience4j-bulkhead-1.3.1.jar:lib/calcite-core-1.21.0.jar:lib/log4j-api-2.8.2.jar:lib/jetty-http-9.4.34.v20201102.jar:lib/guice-servlet-4.1.0.jar:lib/aether-api-0.9.0.M2.jar:lib/netty-buffer-4.1.48.Final.jar:lib/aws-java-sdk-s3-1.11.199.jar:lib/config-magic-0.9.jar:lib/lz4-java-1.7.1.jar:lib/joda-time-2.10.5.jar:lib/jmespath-java-1.11.199.jar:lib/jetty-client-9.4.34.v20201102.jar:lib/netty-codec-dns-4.1.48.Final.jar:lib/jackson-jaxrs-base-2.10.2.jar:lib/curator-client-4.3.0.jar:lib/checker-qual-2.5.7.jar:lib/netty-3.10.6.Final.jar:lib/jetty-util-9.4.34.v20201102.jar:lib/javax.servlet-api-3.1.0.jar:lib/aggdesigner-algorithm-6.0.jar:lib/opencsv-4.6.jar:lib/jetty-server-9.4.34.v20201102.jar:lib/aws-java-sdk-core-1.11.199.jar:lib/netty-handler-4.1.48.Final.jar:lib/jackson-dataformat-smile-2.10.2.jar:lib/javax.activation-api-1.2.0.jar:lib/avatica-server-1.17.0.jar:lib/javax.el-3.0.0.jar:lib/jsr305-2.0.1.jar:lib/jetty-proxy-9.4.34.v20201102.jar:lib/jdbi-2.63.1.jar:lib/hibernate-validator-5.2.5.Final.jar:lib/RoaringBitmap-0.9.0.jar:lib/commons-dbcp2-2.0.1.jar:lib/aws-java-sdk-kms-1.11.199.jar:lib/protobuf-java-3.11.0.jar:lib/derby-10.14.2.0.jar:lib/commons-beanutils-1.9.4.jar:lib/maven-artifact-3.6.0.jar:lib/validation-api-1.1.0.Final.jar:lib/druid-hll-0.20.1.jar:lib/avatica-core-1.17.0.jar:lib/netty-resolver-dns-4.1.48.Final.jar:lib/jline-0.9.94.jar:lib/calcite-linq4j-1.21.0.jar:lib/commons-logging-1.1.1.jar:lib/metrics-core-4.0.0.jar:lib/plexus-interpolation-1.19.jar:lib/janino-3.0.11.jar:lib/druid-indexing-hadoop-0.20.1.jar:lib/commons-io-2.6.jar:lib/guice-assistedinject-4.1.0.jar:lib/jetty-rewrite-9.4.34.v20201102.jar:lib/jetty-servlets-9.4.34.v20201102.jar:lib/jackson-jaxrs-smile-provider-2.10.2.jar:lib/aether-util-0.9.0.M2.jar:lib/jackson-datatype-guava-2.10.2.jar:lib/okhttp-1.0.2.jar:lib/asm-commons-7.1.jar:lib/commons-pool2-2.2.jar:lib/jackson-dataformat-cbor-2.10.2.jar:lib/aether-connector-file-0.9.0.M2.jar:lib/maven-model-3.1.1.jar:lib/netty-codec-http-4.1.48.Final.jar:lib/sigar-1.6.5.132.jar:lib/jackson-annotations-2.10.2.jar:lib/jboss-logging-3.2.1.Final.jar:lib/wagon-provider-api-2.4.jar:lib/aether-connector-okhttp-0.0.9.jar:lib/google-http-client-jackson2-1.26.0.jar:lib/ion-java-1.0.2.jar:lib/druid-console-0.20.1.jar:lib/commons-compress-1.19.jar:lib/guava-16.0.1.jar:lib/log4j-jul-2.8.2.jar:lib/jvm-attach-api-1.5.jar:lib/istack-commons-runtime-3.0.7.jar:lib/async-http-client-2.5.3.jar:lib/commons-collections4-4.2.jar:lib/jackson-core-2.10.2.jar:lib/aether-spi-0.9.0.M2.jar:lib/derbynet-10.14.2.0.jar:lib/log4j-1.2-api-2.8.2.jar:lib/aws-java-sdk-ec2-1.11.199.jar:lib/jsr311-api-1.1.1.jar:lib/jersey-server-1.19.3.jar:lib/avatica-metrics-1.17.0.jar:lib/joni-2.1.27.jar:lib/j2objc-annotations-1.1.jar:lib/slf4j-api-1.7.25.jar:lib/asm-7.1.jar:lib/aopalliance-1.0.jar:lib/maven-repository-metadata-3.1.1.jar:lib/maven-settings-builder-3.1.1.jar:lib/datasketches-memory-1.2.0-incubating.jar:lib/curator-recipes-4.3.0.jar:lib/jetty-security-9.4.34.v20201102.jar:lib/stax-ex-1.8.jar:lib/jetty-servlet-9.4.34.v20201102.jar:lib/druid-indexing-service-0.20.1.jar:lib/netty-common-4.1.48.Final.jar:lib/netty-handler-proxy-4.1.48.Final.jar:lib/extendedset-0.20.1.jar:lib/classmate-1.1.0.jar:lib/commons-compiler-3.0.11.jar:lib/aether-impl-0.9.0.M2.jar:lib/caffeine-2.8.0.jar:lib/jakarta.xml.bind-api-2.3.2.jar:lib/druid-aws-common-0.20.1.jar:lib/vavr-0.10.2.jar:lib/log4j-slf4j-impl-2.8.2.jar:lib/druid-core-0.20.1.jar:lib/error_prone_annotations-2.3.2.jar:lib/esri-geometry-api-2.2.0.jar:lib/jackson-module-guice-2.10.2.jar:lib/jna-4.5.1.jar:lib/netty-transport-native-epoll-4.1.48.Final-linux-x86_64.jar:lib/icu4j-55.1.jar:lib/json-smart-2.3.jar:lib/javax.el-api-3.0.0.jar:lib/jackson-module-jaxb-annotations-2.10.2.jar:lib/commons-codec-1.13.jar:lib/xz-1.8.jar:lib/tesla-aether-0.0.5.jar:lib/json-path-2.3.0.jar:lib/commons-collections-3.2.2.jar:lib/compress-lzf-1.0.4.jar:lib/jcl-over-slf4j-1.7.12.jar:lib/guice-4.1.0.jar:lib/commons-text-1.3.jar:lib/jaxb-api-2.3.1.jar:lib/vavr-match-0.10.2.jar:lib/asm-analysis-7.1.jar:lib/javax.activation-1.2.0.jar:lib/google-http-client-1.26.0.jar:lib/commons-math3-3.6.1.jar:lib/jaxb-runtime-2.3.1.jar:lib/jetty-continuation-9.4.34.v20201102.jar:lib/druid-processing-0.20.1.jar:lib/jcodings-1.0.43.jar:lib/druid-services-0.20.1.jar:lib/httpcore-4.4.11.jar:lib/commons-net-3.6.jar:lib/resilience4j-core-1.3.1.jar:lib/jackson-jaxrs-json-provider-2.10.2.jar:lib/netty-reactive-streams-2.0.0.jar:lib/netty-codec-4.1.48.Final.jar:lib/jersey-core-1.19.3.jar:lib/txw2-2.3.1.jar:lib/maven-model-builder-3.1.1.jar:lib/maven-settings-3.1.1.jar:lib/netty-codec-socks-4.1.48.Final.jar:lib/derbyclient-10.14.2.0.jar:lib/druid-server-0.20.1.jar:lib/commons-lang3-3.8.1.jar:lib/jackson-jq-0.0.10.jar:lib/httpclient-4.5.10.jar:lib/antlr4-runtime-4.5.1.jar:lib/rhino-1.7.11.jar:lib/druid-gcp-common-0.20.1.jar:lib/netty-transport-native-unix-common-4.1.48.Final.jar:lib/jackson-databind-2.10.5.1.jar:lib/zookeeper-3.4.14.jar:lib/audience-annotations-0.5.0.jar:lib/curator-x-discovery-4.3.0.jar:lib/zstd-jni-1.3.3-1.jar:lib/maven-aether-provider-3.1.1.jar:lib/airline-0.7.jar:lib/FastInfoset-1.2.15.jar:lib/jersey-guice-1.19.3.jar:lib/log4j-core-2.8.2.jar:lib/google-oauth-client-1.26.0.jar:lib/spymemcached-2.12.3.jar:lib/shims-0.9.0.jar:lib/netty-resolver-4.1.48.Final.jar:lib/accessors-smart-1.2.jar:lib/jersey-servlet-1.19.3.jar:lib/plexus-utils-3.0.24.jar:lib/jetty-io-9.4.34.v20201102.jar:lib/datasketches-java-1.3.0-incubating.jar:lib/asm-tree-7.1.jar:lib/jakarta.activation-api-1.2.1.jar:lib/curator-framework-4.3.0.jar:lib/netty-transport-4.1.48.Final.jar:lib/druid-sql-0.20.1.jar:
2021-05-10T12:39:24,887 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:java.library.path=/usr/java/packages/lib/amd64:/usr/lib/x86_64-linux-gnu/jni:/lib/x86_64-linux-gnu:/usr/lib/x86_64-linux-gnu:/usr/lib/jni:/lib:/usr/lib
2021-05-10T12:39:24,888 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:java.io.tmpdir=var/tmp
2021-05-10T12:39:24,888 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:java.compiler=<NA>
2021-05-10T12:39:24,888 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:os.name=Linux
2021-05-10T12:39:24,888 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:os.arch=amd64
2021-05-10T12:39:24,888 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:os.version=4.15.0-136-generic
2021-05-10T12:39:24,888 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:user.name=druid
2021-05-10T12:39:24,888 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:user.home=/opt/druid
2021-05-10T12:39:24,888 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:user.dir=/opt/apache-druid-0.20.1
2021-05-10T12:39:24,889 INFO [main] org.apache.zookeeper.ZooKeeper - Initiating client connection, connectString=zookeeper sessionTimeout=30000 watcher=org.apache.curator.ConnectionState@766b6d02
2021-05-10T12:39:24,935 INFO [main] org.apache.curator.framework.imps.CuratorFrameworkImpl - Default schema
2021-05-10T12:39:24,941 INFO [main-SendThread(zookeeper:2181)] org.apache.zookeeper.ClientCnxn - Opening socket connection to server zookeeper/192.168.240.3:2181. Will not attempt to authenticate using SASL (unknown error)
2021-05-10T12:39:24,964 INFO [main-SendThread(zookeeper:2181)] org.apache.zookeeper.ClientCnxn - Socket connection established to zookeeper/192.168.240.3:2181, initiating session
2021-05-10T12:39:25,039 INFO [main-SendThread(zookeeper:2181)] org.apache.zookeeper.ClientCnxn - Session establishment complete on server zookeeper/192.168.240.3:2181, sessionid = 0x1015c6238fa0045, negotiated timeout = 30000
2021-05-10T12:39:25,047 INFO [main-EventThread] org.apache.curator.framework.state.ConnectionStateManager - State change: CONNECTED
2021-05-10T12:39:25,150 INFO [main] org.apache.druid.security.basic.authentication.db.cache.CoordinatorPollingBasicAuthenticatorCacheManager - Starting CoordinatorPollingBasicAuthenticatorCacheManager.
2021-05-10T12:39:25,221 INFO [NodeRoleWatcher[COORDINATOR]] org.apache.druid.curator.discovery.CuratorDruidNodeDiscoveryProvider$NodeRoleWatcher - Node[http://746181ac3f64:8081] of role[coordinator] detected.
2021-05-10T12:39:25,221 INFO [NodeRoleWatcher[COORDINATOR]] org.apache.druid.curator.discovery.CuratorDruidNodeDiscoveryProvider$NodeRoleWatcher - Node watcher of role[coordinator] is now initialized.
2021-05-10T12:39:25,562 INFO [main] org.apache.druid.security.basic.authentication.db.cache.CoordinatorPollingBasicAuthenticatorCacheManager - Started CoordinatorPollingBasicAuthenticatorCacheManager.
2021-05-10T12:39:25,563 INFO [main] org.apache.druid.security.basic.authorization.db.cache.CoordinatorPollingBasicAuthorizerCacheManager - Starting CoordinatorPollingBasicAuthorizerCacheManager.
2021-05-10T12:39:25,712 INFO [main] org.apache.druid.security.basic.authorization.db.cache.CoordinatorPollingBasicAuthorizerCacheManager - Started CoordinatorPollingBasicAuthorizerCacheManager.
2021-05-10T12:39:25,796 INFO [NodeRoleWatcher[OVERLORD]] org.apache.druid.curator.discovery.CuratorDruidNodeDiscoveryProvider$NodeRoleWatcher - Node[http://746181ac3f64:8081] of role[overlord] detected.
2021-05-10T12:39:25,796 INFO [NodeRoleWatcher[OVERLORD]] org.apache.druid.curator.discovery.CuratorDruidNodeDiscoveryProvider$NodeRoleWatcher - Node watcher of role[overlord] is now initialized.
2021-05-10T12:39:25,913 INFO [main] org.apache.druid.indexing.worker.executor.ExecutorLifecycle - Running with task: {
  "type" : "index_kafka",
  "id" : "index_kafka_testdatasource_cfeb942d0a44398_ffnankjj",
  "resource" : {
    "availabilityGroup" : "index_kafka_testdatasource_cfeb942d0a44398",
    "requiredCapacity" : 1
  },
  "dataSchema" : {
    "dataSource" : "testdatasource",
    "timestampSpec" : {
      "column" : "date",
      "format" : "auto",
      "missingValue" : null
    },
    "dimensionsSpec" : {
      "dimensions" : [ {
        "type" : "string",
        "name" : "number",
        "multiValueHandling" : "SORTED_ARRAY",
        "createBitmapIndex" : true
      }, {
        "type" : "long",
        "name" : "duration",
        "multiValueHandling" : "SORTED_ARRAY",
        "createBitmapIndex" : false
      }, {
        "type" : "string",
        "name" : "string",
        "multiValueHandling" : "SORTED_ARRAY",
        "createBitmapIndex" : true
      }, {
        "type" : "string",
        "name" : "otherstring",
        "multiValueHandling" : "SORTED_ARRAY",
        "createBitmapIndex" : true
      }, {
        "type" : "string",
        "name" : "boolean",
        "multiValueHandling" : "SORTED_ARRAY",
        "createBitmapIndex" : true
      } ],
      "dimensionExclusions" : [ "date" ]
    },
    "metricsSpec" : [ ],
    "granularitySpec" : {
      "type" : "uniform",
      "segmentGranularity" : "YEAR",
      "queryGranularity" : {
        "type" : "none"
      },
      "rollup" : false,
      "intervals" : null
    },
    "transformSpec" : {
      "filter" : null,
      "transforms" : [ ]
    }
  },
  "tuningConfig" : {
    "type" : "KafkaTuningConfig",
    "maxRowsInMemory" : 1000000,
    "maxBytesInMemory" : 0,
    "maxRowsPerSegment" : 5000000,
    "maxTotalRows" : null,
    "intermediatePersistPeriod" : "PT10M",
    "basePersistDirectory" : "/opt/apache-druid-0.20.1/var/tmp/druid-realtime-persist2092340825996048896",
    "maxPendingPersists" : 0,
    "indexSpec" : {
      "bitmap" : {
        "type" : "roaring",
        "compressRunOnSerialization" : true
      },
      "dimensionCompression" : "lz4",
      "metricCompression" : "lz4",
      "longEncoding" : "longs",
      "segmentLoader" : null
    },
    "indexSpecForIntermediatePersists" : {
      "bitmap" : {
        "type" : "roaring",
        "compressRunOnSerialization" : true
      },
      "dimensionCompression" : "lz4",
      "metricCompression" : "lz4",
      "longEncoding" : "longs",
      "segmentLoader" : null
    },
    "buildV9Directly" : true,
    "reportParseExceptions" : false,
    "handoffConditionTimeout" : 0,
    "resetOffsetAutomatically" : false,
    "segmentWriteOutMediumFactory" : null,
    "intermediateHandoffPeriod" : "PT30M",
    "logParseExceptions" : true,
    "maxParseExceptions" : 2147483647,
    "maxSavedParseExceptions" : 0,
    "skipSequenceNumberAvailabilityCheck" : false
  },
  "ioConfig" : {
    "type" : "kafka",
    "taskGroupId" : 0,
    "baseSequenceName" : "index_kafka_testdatasource_cfeb942d0a44398",
    "startPartitions" : {
      "type" : "end",
      "stream" : "testdatasource",
      "topic" : "testdatasource",
      "partitionSequenceNumberMap" : {
        "0" : 0
      },
      "partitionOffsetMap" : {
        "0" : 0
      }
    },
    "endPartitions" : {
      "type" : "end",
      "stream" : "testdatasource",
      "topic" : "testdatasource",
      "partitionSequenceNumberMap" : {
        "0" : 9223372036854775807
      },
      "partitionOffsetMap" : {
        "0" : 9223372036854775807
      }
    },
    "startSequenceNumbers" : {
      "type" : "start",
      "stream" : "testdatasource",
      "topic" : "testdatasource",
      "partitionSequenceNumberMap" : {
        "0" : 0
      },
      "partitionOffsetMap" : {
        "0" : 0
      },
      "exclusivePartitions" : [ ]
    },
    "endSequenceNumbers" : {
      "type" : "end",
      "stream" : "testdatasource",
      "topic" : "testdatasource",
      "partitionSequenceNumberMap" : {
        "0" : 9223372036854775807
      },
      "partitionOffsetMap" : {
        "0" : 9223372036854775807
      }
    },
    "consumerProperties" : {
      "bootstrap.servers" : "kafka-broker:00001"
    },
    "pollTimeout" : 100,
    "useTransaction" : true,
    "minimumMessageTime" : null,
    "maximumMessageTime" : null,
    "inputFormat" : {
      "type" : "json",
      "flattenSpec" : {
        "useFieldDiscovery" : true,
        "fields" : [ ]
      },
      "featureSpec" : { }
    }
  },
  "context" : {
    "checkpoints" : "{\"0\":{\"0\":0}}",
    "IS_INCREMENTAL_HANDOFF_SUPPORTED" : true,
    "forceTimeChunkLock" : true
  },
  "groupId" : "index_kafka_testdatasource",
  "dataSource" : "testdatasource"
}
2021-05-10T12:39:25,915 INFO [main] org.apache.druid.indexing.worker.executor.ExecutorLifecycle - Attempting to lock file[var/druid/task/index_kafka_testdatasource_cfeb942d0a44398_ffnankjj/lock].
2021-05-10T12:39:25,922 INFO [main] org.apache.druid.indexing.worker.executor.ExecutorLifecycle - Acquired lock file[var/druid/task/index_kafka_testdatasource_cfeb942d0a44398_ffnankjj/lock] in 6ms.
2021-05-10T12:39:25,934 INFO [task-runner-0-priority-0] org.apache.druid.indexing.overlord.SingleTaskBackgroundRunner - Running task: index_kafka_testdatasource_cfeb942d0a44398_ffnankjj
2021-05-10T12:39:25,950 INFO [main] org.apache.druid.server.coordination.SegmentLoadDropHandler - Starting...
2021-05-10T12:39:25,950 INFO [main] org.apache.druid.server.coordination.SegmentLoadDropHandler - Started.
2021-05-10T12:39:25,951 INFO [main] org.apache.druid.server.coordination.ZkCoordinator - Starting zkCoordinator for server[23bfaec7cc1e:8100]
2021-05-10T12:39:26,004 INFO [main] org.apache.druid.java.util.common.lifecycle.Lifecycle - Starting lifecycle [module] stage [SERVER]
2021-05-10T12:39:26,008 INFO [main] org.eclipse.jetty.server.Server - jetty-9.4.34.v20201102; built: 2020-11-02T14:15:39.302Z; git: e46af88704a893fc12cb0e3bf46e2c7b48a009e7; jvm 1.8.0_275-8u275-b01-1~deb9u1-b01
2021-05-10T12:39:26,047 INFO [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Starting with sequences: [SequenceMetadata{sequenceId=0, sequenceName='index_kafka_testdatasource_cfeb942d0a44398_0', assignments=[0], startOffsets={0=0}, exclusiveStartPartitions=[], endOffsets={0=9223372036854775807}, sentinel=false, checkpointed=false}]
2021-05-10T12:39:26,223 INFO [task-runner-0-priority-0] org.apache.kafka.clients.consumer.ConsumerConfig - ConsumerConfig values: 
	allow.auto.create.topics = true
	auto.commit.interval.ms = 5000
	auto.offset.reset = none
	bootstrap.servers = [kafka-broker:00001]
	check.crcs = true
	client.dns.lookup = use_all_dns_ips
	client.id = consumer-kafka-supervisor-kgmamklp-1
	client.rack = 
	connections.max.idle.ms = 540000
	default.api.timeout.ms = 60000
	enable.auto.commit = false
	exclude.internal.topics = true
	fetch.max.bytes = 52428800
	fetch.max.wait.ms = 500
	fetch.min.bytes = 1
	group.id = kafka-supervisor-kgmamklp
	group.instance.id = null
	heartbeat.interval.ms = 3000
	interceptor.classes = []
	internal.leave.group.on.close = true
	internal.throw.on.fetch.stable.offset.unsupported = false
	isolation.level = read_committed
	key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
	max.partition.fetch.bytes = 1048576
	max.poll.interval.ms = 300000
	max.poll.records = 500
	metadata.max.age.ms = 10000
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
	receive.buffer.bytes = 65536
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.mechanism = GSSAPI
	security.protocol = PLAINTEXT
	security.providers = null
	send.buffer.bytes = 131072
	session.timeout.ms = 10000
	ssl.cipher.suites = null
	ssl.enabled.protocols = [TLSv1.2]
	ssl.endpoint.identification.algorithm = https
	ssl.engine.factory.class = null
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLSv1.2
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.location = null
	ssl.truststore.password = null
	ssl.truststore.type = JKS
	value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer

2021-05-10T12:39:26,512 INFO [main] org.eclipse.jetty.server.session - DefaultSessionIdManager workerName=node0
2021-05-10T12:39:26,513 INFO [main] org.eclipse.jetty.server.session - No SessionScavenger set, using defaults
2021-05-10T12:39:26,514 INFO [main] org.eclipse.jetty.server.session - node0 Scavenging every 600000ms
2021-05-10T12:39:26,530 INFO [task-runner-0-priority-0] org.apache.kafka.common.utils.AppInfoParser - Kafka version: 2.6.0
2021-05-10T12:39:26,530 INFO [task-runner-0-priority-0] org.apache.kafka.common.utils.AppInfoParser - Kafka commitId: 62abe01bee039651
2021-05-10T12:39:26,530 INFO [task-runner-0-priority-0] org.apache.kafka.common.utils.AppInfoParser - Kafka startTimeMs: 1620650366527
2021-05-10T12:39:26,532 INFO [task-runner-0-priority-0] org.apache.druid.server.coordination.CuratorDataSegmentServerAnnouncer - Announcing self[DruidServerMetadata{name='23bfaec7cc1e:8100', hostAndPort='23bfaec7cc1e:8100', hostAndTlsPort='null', maxSize=0, tier='_default_tier', type=indexer-executor, priority=0}] at [/druid/announcements/23bfaec7cc1e:8100]
2021-05-10T12:39:26,559 INFO [task-runner-0-priority-0] org.apache.druid.curator.discovery.CuratorDruidNodeAnnouncer - Announced self [{"druidNode":{"service":"druid/middleManager","host":"23bfaec7cc1e","bindOnHost":false,"plaintextPort":8100,"port":-1,"tlsPort":-1,"enablePlaintextPort":true,"enableTlsPort":false},"nodeType":"peon","services":{"dataNodeService":{"type":"dataNodeService","tier":"_default_tier","maxSize":0,"type":"indexer-executor","priority":0},"lookupNodeService":{"type":"lookupNodeService","lookupTier":"__default"}}}].
2021-05-10T12:39:26,848 INFO [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Initialized sequences: SequenceMetadata{sequenceId=0, sequenceName='index_kafka_testdatasource_cfeb942d0a44398_0', assignments=[0], startOffsets={0=0}, exclusiveStartPartitions=[], endOffsets={0=9223372036854775807}, sentinel=false, checkpointed=false}
2021-05-10T12:39:26,875 INFO [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Adding partition[0], start[0] -> end[9223372036854775807] to assignment.
2021-05-10T12:39:26,887 INFO [task-runner-0-priority-0] org.apache.kafka.clients.consumer.KafkaConsumer - [Consumer clientId=consumer-kafka-supervisor-kgmamklp-1, groupId=kafka-supervisor-kgmamklp] Subscribed to partition(s): testdatasource-0
2021-05-10T12:39:26,902 INFO [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Seeking partition[0] to[0].
2021-05-10T12:39:26,907 INFO [task-runner-0-priority-0] org.apache.kafka.clients.consumer.KafkaConsumer - [Consumer clientId=consumer-kafka-supervisor-kgmamklp-1, groupId=kafka-supervisor-kgmamklp] Seeking to offset 0 for partition testdatasource-0
2021-05-10T12:39:26,953 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Registering com.fasterxml.jackson.jaxrs.json.JacksonJsonProvider as a provider class
2021-05-10T12:39:26,954 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Registering com.fasterxml.jackson.jaxrs.smile.JacksonSmileProvider as a provider class
2021-05-10T12:39:26,955 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Registering org.apache.druid.server.initialization.jetty.CustomExceptionMapper as a provider class
2021-05-10T12:39:26,960 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Registering org.apache.druid.server.initialization.jetty.ForbiddenExceptionMapper as a provider class
2021-05-10T12:39:26,960 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Registering org.apache.druid.server.initialization.jetty.BadRequestExceptionMapper as a provider class
2021-05-10T12:39:26,963 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Registering org.apache.druid.server.StatusResource as a root resource class
2021-05-10T12:39:26,966 INFO [main] com.sun.jersey.server.impl.application.WebApplicationImpl - Initiating Jersey application, version 'Jersey: 1.19.3 10/24/2016 03:43 PM'
2021-05-10T12:39:27,272 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Binding org.apache.druid.server.initialization.jetty.CustomExceptionMapper to GuiceManagedComponentProvider with the scope "Singleton"
2021-05-10T12:39:27,274 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Binding org.apache.druid.server.initialization.jetty.ForbiddenExceptionMapper to GuiceManagedComponentProvider with the scope "Singleton"
2021-05-10T12:39:27,275 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Binding org.apache.druid.server.initialization.jetty.BadRequestExceptionMapper to GuiceManagedComponentProvider with the scope "Singleton"
2021-05-10T12:39:27,275 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Binding com.fasterxml.jackson.jaxrs.json.JacksonJsonProvider to GuiceManagedComponentProvider with the scope "Singleton"
2021-05-10T12:39:27,306 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Binding com.fasterxml.jackson.jaxrs.smile.JacksonSmileProvider to GuiceManagedComponentProvider with the scope "Singleton"
2021-05-10T12:39:29,742 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Binding org.apache.druid.security.basic.BasicSecurityResourceFilter to GuiceInstantiatedComponentProvider
2021-05-10T12:39:29,862 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Binding org.apache.druid.security.basic.authentication.endpoint.BasicAuthenticatorResource to GuiceInstantiatedComponentProvider
2021-05-10T12:39:29,933 INFO [task-runner-0-priority-0] org.apache.kafka.clients.Metadata - [Consumer clientId=consumer-kafka-supervisor-kgmamklp-1, groupId=kafka-supervisor-kgmamklp] Cluster ID: OaxptNnQTYG_euMhPinTvQ
2021-05-10T12:39:29,943 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Binding org.apache.druid.security.basic.authorization.endpoint.BasicAuthorizerResource to GuiceInstantiatedComponentProvider
2021-05-10T12:39:29,948 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Binding org.apache.druid.server.http.security.StateResourceFilter to GuiceInstantiatedComponentProvider
2021-05-10T12:39:29,992 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Binding org.apache.druid.server.http.SegmentListerResource to GuiceInstantiatedComponentProvider
2021-05-10T12:39:30,011 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Binding org.apache.druid.server.http.HistoricalResource to GuiceInstantiatedComponentProvider
2021-05-10T12:39:30,022 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Binding org.apache.druid.server.QueryResource to GuiceInstantiatedComponentProvider
2021-05-10T12:39:30,053 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Binding org.apache.druid.segment.realtime.firehose.ChatHandlerResource to GuiceInstantiatedComponentProvider
2021-05-10T12:39:30,062 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Binding org.apache.druid.server.http.security.ConfigResourceFilter to GuiceInstantiatedComponentProvider
2021-05-10T12:39:30,091 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Binding org.apache.druid.query.lookup.LookupListeningResource to GuiceInstantiatedComponentProvider
2021-05-10T12:39:30,102 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Binding org.apache.druid.query.lookup.LookupIntrospectionResource to GuiceInstantiatedComponentProvider
2021-05-10T12:39:30,109 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Binding org.apache.druid.server.StatusResource to GuiceManagedComponentProvider with the scope "Undefined"
2021-05-10T12:39:30,280 INFO [main] org.eclipse.jetty.server.handler.ContextHandler - Started o.e.j.s.ServletContextHandler@6d35ff7b{/,null,AVAILABLE}
2021-05-10T12:39:30,389 INFO [main] org.eclipse.jetty.server.AbstractConnector - Started ServerConnector@73dbe25{HTTP/1.1, (http/1.1)}{0.0.0.0:8100}
2021-05-10T12:39:30,390 INFO [main] org.eclipse.jetty.server.Server - Started @21611ms
2021-05-10T12:39:30,390 INFO [main] org.apache.druid.java.util.common.lifecycle.Lifecycle - Starting lifecycle [module] stage [ANNOUNCEMENTS]
2021-05-10T12:39:30,547 INFO [main] org.apache.druid.java.util.common.lifecycle.Lifecycle - Successfully started lifecycle [module]
2021-05-10T12:39:30,796 INFO [task-runner-0-priority-0] org.apache.druid.segment.realtime.appenderator.BaseAppenderatorDriver - New segment[testdatasource_2010-10-10T00:00:00.000Z_2010-10-11T00:00:00.000Z_2021-05-10T12:39:30.726Z] for sequenceName[index_kafka_testdatasource_cfeb942d0a44398_0].
2021-05-10T12:39:31,240 INFO [task-runner-0-priority-0] org.apache.druid.server.coordination.BatchDataSegmentAnnouncer - Announcing segment[testdatasource_2010-10-10T00:00:00.000Z_2010-10-11T00:00:00.000Z_2021-05-10T12:39:30.726Z] at new path[/druid/segments/23bfaec7cc1e:8100/23bfaec7cc1e:8100_indexer-executor__default_tier_2021-05-10T12:39:31.215Z_a35ec00a28794f1b8a2b05897cb12fee0]
2021-05-10T12:39:32,531 DEBUG [qtp39642165-117] org.apache.druid.jetty.RequestLog - 192.168.240.7 POST //23bfaec7cc1e:8100/druid/v2/ HTTP/1.1
2021-05-10T12:39:32,994 DEBUG [qtp39642165-112] org.apache.druid.jetty.RequestLog - 192.168.240.7 POST //23bfaec7cc1e:8100/druid/v2/ HTTP/1.1
2021-05-10T12:39:33,603 DEBUG [qtp39642165-113] org.apache.druid.jetty.RequestLog - 192.168.240.7 POST //23bfaec7cc1e:8100/druid/v2/ HTTP/1.1
2021-05-10T12:39:37,893 DEBUG [qtp39642165-119] org.apache.druid.jetty.RequestLog - 192.168.240.5 GET //23bfaec7cc1e:8100/druid/worker/v1/chat/index_kafka_testdatasource_cfeb942d0a44398_ffnankjj/status HTTP/1.1
2021-05-10T12:39:37,997 DEBUG [qtp39642165-123] org.apache.druid.jetty.RequestLog - 192.168.240.5 GET //23bfaec7cc1e:8100/druid/worker/v1/chat/index_kafka_testdatasource_cfeb942d0a44398_ffnankjj/rowStats HTTP/1.1
2021-05-10T12:39:38,222 DEBUG [qtp39642165-119] org.apache.druid.jetty.RequestLog - 192.168.240.5 GET //23bfaec7cc1e:8100/druid/worker/v1/chat/index_kafka_testdatasource_cfeb942d0a44398_ffnankjj/checkpoints HTTP/1.1
2021-05-10T12:39:38,341 DEBUG [qtp39642165-123] org.apache.druid.jetty.RequestLog - 192.168.240.5 GET //23bfaec7cc1e:8100/druid/worker/v1/chat/index_kafka_testdatasource_cfeb942d0a44398_ffnankjj/time/start HTTP/1.1
2021-05-10T12:39:38,610 INFO [parent-monitor-0] org.apache.druid.indexing.worker.executor.ExecutorLifecycle - Triggering JVM shutdown.
2021-05-10T12:39:38,624 INFO [Thread-50] org.apache.druid.cli.CliPeon - Running shutdown hook
2021-05-10T12:39:38,625 INFO [Thread-50] org.apache.druid.java.util.common.lifecycle.Lifecycle - Stopping lifecycle [module] stage [ANNOUNCEMENTS]
2021-05-10T12:39:38,628 INFO [Thread-50] org.apache.druid.curator.announcement.Announcer - Unannouncing [/druid/announcements/23bfaec7cc1e:8100]
2021-05-10T12:39:38,669 INFO [Thread-50] org.apache.druid.curator.announcement.Announcer - Unannouncing [/druid/segments/23bfaec7cc1e:8100/23bfaec7cc1e:8100_indexer-executor__default_tier_2021-05-10T12:39:31.215Z_a35ec00a28794f1b8a2b05897cb12fee0]
2021-05-10T12:39:38,674 INFO [Thread-50] org.apache.druid.curator.announcement.Announcer - Unannouncing [/druid/internal-discovery/PEON/23bfaec7cc1e:8100]
2021-05-10T12:39:38,680 INFO [Thread-50] org.apache.druid.java.util.common.lifecycle.Lifecycle - Stopping lifecycle [module] stage [SERVER]
2021-05-10T12:39:38,690 INFO [Thread-50] org.eclipse.jetty.server.AbstractConnector - Stopped ServerConnector@73dbe25{HTTP/1.1, (http/1.1)}{0.0.0.0:8100}
2021-05-10T12:39:38,691 INFO [Thread-50] org.eclipse.jetty.server.session - node0 Stopped scavenging
2021-05-10T12:39:38,693 INFO [Thread-50] org.eclipse.jetty.server.handler.ContextHandler - Stopped o.e.j.s.ServletContextHandler@6d35ff7b{/,null,STOPPED}
2021-05-10T12:39:38,699 INFO [Thread-50] org.apache.druid.java.util.common.lifecycle.Lifecycle - Stopping lifecycle [module] stage [NORMAL]
2021-05-10T12:39:38,700 INFO [Thread-50] org.apache.druid.server.coordination.ZkCoordinator - Stopping ZkCoordinator for [DruidServerMetadata{name='23bfaec7cc1e:8100', hostAndPort='23bfaec7cc1e:8100', hostAndTlsPort='null', maxSize=0, tier='_default_tier', type=indexer-executor, priority=0}]
2021-05-10T12:39:38,700 INFO [Thread-50] org.apache.druid.server.coordination.SegmentLoadDropHandler - Stopping...
2021-05-10T12:39:38,700 INFO [Thread-50] org.apache.druid.server.coordination.SegmentLoadDropHandler - Stopped.
2021-05-10T12:39:38,701 INFO [Thread-50] org.apache.druid.indexing.overlord.SingleTaskBackgroundRunner - Starting graceful shutdown of task[index_kafka_testdatasource_cfeb942d0a44398_ffnankjj].
2021-05-10T12:39:38,701 INFO [Thread-50] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Stopping forcefully (status: [READING])
2021-05-10T12:39:38,725 INFO [LookupExtractorFactoryContainerProvider-MainThread] org.apache.druid.query.lookup.LookupReferencesManager - Lookup Management loop exited. Lookup notices are not handled anymore.
2021-05-10T12:39:38,730 INFO [Thread-50] org.apache.druid.security.basic.authorization.db.cache.CoordinatorPollingBasicAuthorizerCacheManager - CoordinatorPollingBasicAuthorizerCacheManager is stopping.
2021-05-10T12:39:38,730 INFO [Thread-50] org.apache.druid.security.basic.authorization.db.cache.CoordinatorPollingBasicAuthorizerCacheManager - CoordinatorPollingBasicAuthorizerCacheManager is stopped.
2021-05-10T12:39:38,731 INFO [Thread-50] org.apache.druid.security.basic.authentication.db.cache.CoordinatorPollingBasicAuthenticatorCacheManager - CoordinatorPollingBasicAuthenticatorCacheManager is stopping.
2021-05-10T12:39:38,731 INFO [Thread-50] org.apache.druid.security.basic.authentication.db.cache.CoordinatorPollingBasicAuthenticatorCacheManager - CoordinatorPollingBasicAuthenticatorCacheManager is stopped.
2021-05-10T12:39:38,705 ERROR [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Encountered exception in run() before persisting.
org.apache.kafka.common.errors.InterruptException: java.lang.InterruptedException
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.maybeThrowInterruptException(ConsumerNetworkClient.java:520) ~[?:?]
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:281) ~[?:?]
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:236) ~[?:?]
	at org.apache.kafka.clients.consumer.KafkaConsumer.pollForFetches(KafkaConsumer.java:1301) ~[?:?]
	at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1237) ~[?:?]
	at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1210) ~[?:?]
	at org.apache.druid.indexing.kafka.KafkaRecordSupplier.poll(KafkaRecordSupplier.java:124) ~[?:?]
	at org.apache.druid.indexing.kafka.IncrementalPublishingKafkaIndexTaskRunner.getRecords(IncrementalPublishingKafkaIndexTaskRunner.java:98) ~[?:?]
	at org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner.runInternal(SeekableStreamIndexTaskRunner.java:603) [druid-indexing-service-0.20.1.jar:0.20.1]
	at org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner.run(SeekableStreamIndexTaskRunner.java:267) [druid-indexing-service-0.20.1.jar:0.20.1]
	at org.apache.druid.indexing.seekablestream.SeekableStreamIndexTask.run(SeekableStreamIndexTask.java:145) [druid-indexing-service-0.20.1.jar:0.20.1]
	at org.apache.druid.indexing.overlord.SingleTaskBackgroundRunner$SingleTaskBackgroundRunnerCallable.call(SingleTaskBackgroundRunner.java:451) [druid-indexing-service-0.20.1.jar:0.20.1]
	at org.apache.druid.indexing.overlord.SingleTaskBackgroundRunner$SingleTaskBackgroundRunnerCallable.call(SingleTaskBackgroundRunner.java:423) [druid-indexing-service-0.20.1.jar:0.20.1]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_275]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_275]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_275]
	at java.lang.Thread.run(Thread.java:748) [?:1.8.0_275]
Caused by: java.lang.InterruptedException
	... 17 more
2021-05-10T12:39:38,837 INFO [task-runner-0-priority-0] org.apache.druid.server.coordination.BatchDataSegmentAnnouncer - Unannouncing segment[testdatasource_2010-10-10T00:00:00.000Z_2010-10-11T00:00:00.000Z_2021-05-10T12:39:30.726Z] at path[/druid/segments/23bfaec7cc1e:8100/23bfaec7cc1e:8100_indexer-executor__default_tier_2021-05-10T12:39:31.215Z_a35ec00a28794f1b8a2b05897cb12fee0]
2021-05-10T12:39:39,067 WARN [HttpPostEmitter-1] org.apache.druid.java.util.common.RetryUtils - Retrying (1 of 2) in 925ms.
java.util.concurrent.ExecutionException: java.net.UnknownHostException: druid_exporter: Temporary failure in name resolution
	at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357) ~[?:1.8.0_275]
	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908) ~[?:1.8.0_275]
	at org.asynchttpclient.netty.NettyResponseFuture.get(NettyResponseFuture.java:202) ~[async-http-client-2.5.3.jar:?]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread.send(HttpPostEmitter.java:759) ~[druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread.access$1900(HttpPostEmitter.java:464) ~[druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread$1.perform(HttpPostEmitter.java:672) ~[druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread$1.perform(HttpPostEmitter.java:668) ~[druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.common.RetryUtils.retry(RetryUtils.java:87) [druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.common.RetryUtils.retry(RetryUtils.java:115) [druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.common.RetryUtils.retry(RetryUtils.java:105) [druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread.sendWithRetries(HttpPostEmitter.java:666) [druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread.emit(HttpPostEmitter.java:574) [druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread.emitBatches(HttpPostEmitter.java:550) [druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread.run(HttpPostEmitter.java:503) [druid-core-0.20.1.jar:0.20.1]
Caused by: java.net.UnknownHostException: druid_exporter: Temporary failure in name resolution
	at java.net.Inet4AddressImpl.lookupAllHostAddr(Native Method) ~[?:1.8.0_275]
	at java.net.InetAddress$2.lookupAllHostAddr(InetAddress.java:929) ~[?:1.8.0_275]
	at java.net.InetAddress.getAddressesFromNameService(InetAddress.java:1324) ~[?:1.8.0_275]
	at java.net.InetAddress.getAllByName0(InetAddress.java:1277) ~[?:1.8.0_275]
	at java.net.InetAddress.getAllByName(InetAddress.java:1193) ~[?:1.8.0_275]
	at java.net.InetAddress.getAllByName(InetAddress.java:1127) ~[?:1.8.0_275]
	at io.netty.util.internal.SocketUtils$9.run(SocketUtils.java:169) ~[netty-common-4.1.48.Final.jar:4.1.48.Final]
	at io.netty.util.internal.SocketUtils$9.run(SocketUtils.java:166) ~[netty-common-4.1.48.Final.jar:4.1.48.Final]
	at java.security.AccessController.doPrivileged(Native Method) ~[?:1.8.0_275]
	at io.netty.util.internal.SocketUtils.allAddressesByName(SocketUtils.java:166) ~[netty-common-4.1.48.Final.jar:4.1.48.Final]
	at io.netty.resolver.DefaultNameResolver.doResolveAll(DefaultNameResolver.java:50) ~[netty-resolver-4.1.48.Final.jar:4.1.48.Final]
	at io.netty.resolver.SimpleNameResolver.resolveAll(SimpleNameResolver.java:79) ~[netty-resolver-4.1.48.Final.jar:4.1.48.Final]
	at io.netty.resolver.SimpleNameResolver.resolveAll(SimpleNameResolver.java:71) ~[netty-resolver-4.1.48.Final.jar:4.1.48.Final]
	at org.asynchttpclient.resolver.RequestHostnameResolver.resolve(RequestHostnameResolver.java:50) ~[async-http-client-2.5.3.jar:?]
	at org.asynchttpclient.netty.request.NettyRequestSender.resolveAddresses(NettyRequestSender.java:357) ~[async-http-client-2.5.3.jar:?]
	at org.asynchttpclient.netty.request.NettyRequestSender.sendRequestWithNewChannel(NettyRequestSender.java:300) ~[async-http-client-2.5.3.jar:?]
	at org.asynchttpclient.netty.request.NettyRequestSender.sendRequestWithCertainForceConnect(NettyRequestSender.java:142) ~[async-http-client-2.5.3.jar:?]
	at org.asynchttpclient.netty.request.NettyRequestSender.sendRequest(NettyRequestSender.java:113) ~[async-http-client-2.5.3.jar:?]
	at org.asynchttpclient.DefaultAsyncHttpClient.execute(DefaultAsyncHttpClient.java:241) ~[async-http-client-2.5.3.jar:?]
	at org.asynchttpclient.DefaultAsyncHttpClient.executeRequest(DefaultAsyncHttpClient.java:210) ~[async-http-client-2.5.3.jar:?]
	at org.asynchttpclient.DefaultAsyncHttpClient.executeRequest(DefaultAsyncHttpClient.java:231) ~[async-http-client-2.5.3.jar:?]
	at org.asynchttpclient.DefaultAsyncHttpClient.executeRequest(DefaultAsyncHttpClient.java:236) ~[async-http-client-2.5.3.jar:?]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread.send(HttpPostEmitter.java:754) ~[druid-core-0.20.1.jar:0.20.1]
	... 10 more
2021-05-10T12:39:39,211 ERROR [[index_kafka_testdatasource_cfeb942d0a44398_ffnankjj]-appenderator-persist] org.apache.druid.segment.realtime.appenderator.AppenderatorImpl - Incremental persist failed: {class=org.apache.druid.segment.realtime.appenderator.AppenderatorImpl, segment=testdatasource_2010-10-10T00:00:00.000Z_2010-10-11T00:00:00.000Z_2021-05-10T12:39:30.726Z, dataSource=testdatasource, count=0}
2021-05-10T12:39:39,215 INFO [task-runner-0-priority-0] org.apache.druid.curator.discovery.CuratorDruidNodeAnnouncer - Unannounced self [{"druidNode":{"service":"druid/middleManager","host":"23bfaec7cc1e","bindOnHost":false,"plaintextPort":8100,"port":-1,"tlsPort":-1,"enablePlaintextPort":true,"enableTlsPort":false},"nodeType":"peon","services":{"dataNodeService":{"type":"dataNodeService","tier":"_default_tier","maxSize":0,"type":"indexer-executor","priority":0},"lookupNodeService":{"type":"lookupNodeService","lookupTier":"__default"}}}].
2021-05-10T12:39:39,215 ERROR [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Encountered exception while running task.
org.apache.kafka.common.errors.InterruptException: java.lang.InterruptedException
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.maybeThrowInterruptException(ConsumerNetworkClient.java:520) ~[?:?]
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:281) ~[?:?]
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:236) ~[?:?]
	at org.apache.kafka.clients.consumer.KafkaConsumer.pollForFetches(KafkaConsumer.java:1301) ~[?:?]
	at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1237) ~[?:?]
	at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1210) ~[?:?]
	at org.apache.druid.indexing.kafka.KafkaRecordSupplier.poll(KafkaRecordSupplier.java:124) ~[?:?]
	at org.apache.druid.indexing.kafka.IncrementalPublishingKafkaIndexTaskRunner.getRecords(IncrementalPublishingKafkaIndexTaskRunner.java:98) ~[?:?]
	at org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner.runInternal(SeekableStreamIndexTaskRunner.java:603) ~[druid-indexing-service-0.20.1.jar:0.20.1]
	at org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner.run(SeekableStreamIndexTaskRunner.java:267) [druid-indexing-service-0.20.1.jar:0.20.1]
	at org.apache.druid.indexing.seekablestream.SeekableStreamIndexTask.run(SeekableStreamIndexTask.java:145) [druid-indexing-service-0.20.1.jar:0.20.1]
	at org.apache.druid.indexing.overlord.SingleTaskBackgroundRunner$SingleTaskBackgroundRunnerCallable.call(SingleTaskBackgroundRunner.java:451) [druid-indexing-service-0.20.1.jar:0.20.1]
	at org.apache.druid.indexing.overlord.SingleTaskBackgroundRunner$SingleTaskBackgroundRunnerCallable.call(SingleTaskBackgroundRunner.java:423) [druid-indexing-service-0.20.1.jar:0.20.1]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_275]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_275]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_275]
	at java.lang.Thread.run(Thread.java:748) [?:1.8.0_275]
	Suppressed: java.lang.InterruptedException
		at java.util.concurrent.FutureTask.awaitDone(FutureTask.java:404) ~[?:1.8.0_275]
		at java.util.concurrent.FutureTask.get(FutureTask.java:191) ~[?:1.8.0_275]
		at org.apache.druid.segment.realtime.appenderator.StreamAppenderatorDriver.persist(StreamAppenderatorDriver.java:231) ~[druid-server-0.20.1.jar:0.20.1]
		at org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner.runInternal(SeekableStreamIndexTaskRunner.java:756) ~[druid-indexing-service-0.20.1.jar:0.20.1]
		at org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner.run(SeekableStreamIndexTaskRunner.java:267) [druid-indexing-service-0.20.1.jar:0.20.1]
		at org.apache.druid.indexing.seekablestream.SeekableStreamIndexTask.run(SeekableStreamIndexTask.java:145) [druid-indexing-service-0.20.1.jar:0.20.1]
		at org.apache.druid.indexing.overlord.SingleTaskBackgroundRunner$SingleTaskBackgroundRunnerCallable.call(SingleTaskBackgroundRunner.java:451) [druid-indexing-service-0.20.1.jar:0.20.1]
		at org.apache.druid.indexing.overlord.SingleTaskBackgroundRunner$SingleTaskBackgroundRunnerCallable.call(SingleTaskBackgroundRunner.java:423) [druid-indexing-service-0.20.1.jar:0.20.1]
		at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_275]
		at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_275]
		at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_275]
		at java.lang.Thread.run(Thread.java:748) [?:1.8.0_275]
Caused by: java.lang.InterruptedException
	... 17 more
2021-05-10T12:39:39,244 INFO [task-runner-0-priority-0] org.apache.druid.indexing.worker.executor.ExecutorLifecycle - Task completed with status: {
  "id" : "index_kafka_testdatasource_cfeb942d0a44398_ffnankjj",
  "status" : "FAILED",
  "duration" : 13301,
  "errorMsg" : "org.apache.kafka.common.errors.InterruptException: java.lang.InterruptedException\n\tat org.apache.kaf...",
  "location" : {
    "host" : null,
    "port" : -1,
    "tlsPort" : -1
  }
}
2021-05-10T12:39:39,248 INFO [main] org.apache.druid.cli.CliPeon - Thread [Thread[Thread-50,5,main]] is non daemon.
2021-05-10T12:39:39,248 INFO [main] org.apache.druid.java.util.common.lifecycle.Lifecycle - Lifecycle [module] already stopped and stop was called. Silently skipping
Cannot remove shutdown hook, already shutting down!
Finished peon task
2021-05-10T12:39:39,999 WARN [HttpPostEmitter-1] org.apache.druid.java.util.common.RetryUtils - Retrying (2 of 2) in 2,298ms.
java.util.concurrent.ExecutionException: java.net.UnknownHostException: druid_exporter
	at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357) ~[?:1.8.0_275]
	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908) ~[?:1.8.0_275]
	at org.asynchttpclient.netty.NettyResponseFuture.get(NettyResponseFuture.java:202) ~[async-http-client-2.5.3.jar:?]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread.send(HttpPostEmitter.java:759) ~[druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread.access$1900(HttpPostEmitter.java:464) ~[druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread$1.perform(HttpPostEmitter.java:672) ~[druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread$1.perform(HttpPostEmitter.java:668) ~[druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.common.RetryUtils.retry(RetryUtils.java:87) [druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.common.RetryUtils.retry(RetryUtils.java:115) [druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.common.RetryUtils.retry(RetryUtils.java:105) [druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread.sendWithRetries(HttpPostEmitter.java:666) [druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread.emit(HttpPostEmitter.java:574) [druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread.emitBatches(HttpPostEmitter.java:550) [druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread.run(HttpPostEmitter.java:503) [druid-core-0.20.1.jar:0.20.1]
Caused by: java.net.UnknownHostException: druid_exporter
	at java.net.InetAddress.getAllByName0(InetAddress.java:1281) ~[?:1.8.0_275]
	at java.net.InetAddress.getAllByName(InetAddress.java:1193) ~[?:1.8.0_275]
	at java.net.InetAddress.getAllByName(InetAddress.java:1127) ~[?:1.8.0_275]
	at io.netty.util.internal.SocketUtils$9.run(SocketUtils.java:169) ~[netty-common-4.1.48.Final.jar:4.1.48.Final]
	at io.netty.util.internal.SocketUtils$9.run(SocketUtils.java:166) ~[netty-common-4.1.48.Final.jar:4.1.48.Final]
	at java.security.AccessController.doPrivileged(Native Method) ~[?:1.8.0_275]
	at io.netty.util.internal.SocketUtils.allAddressesByName(SocketUtils.java:166) ~[netty-common-4.1.48.Final.jar:4.1.48.Final]
	at io.netty.resolver.DefaultNameResolver.doResolveAll(DefaultNameResolver.java:50) ~[netty-resolver-4.1.48.Final.jar:4.1.48.Final]
	at io.netty.resolver.SimpleNameResolver.resolveAll(SimpleNameResolver.java:79) ~[netty-resolver-4.1.48.Final.jar:4.1.48.Final]
	at io.netty.resolver.SimpleNameResolver.resolveAll(SimpleNameResolver.java:71) ~[netty-resolver-4.1.48.Final.jar:4.1.48.Final]
	at org.asynchttpclient.resolver.RequestHostnameResolver.resolve(RequestHostnameResolver.java:50) ~[async-http-client-2.5.3.jar:?]
	at org.asynchttpclient.netty.request.NettyRequestSender.resolveAddresses(NettyRequestSender.java:357) ~[async-http-client-2.5.3.jar:?]
	at org.asynchttpclient.netty.request.NettyRequestSender.sendRequestWithNewChannel(NettyRequestSender.java:300) ~[async-http-client-2.5.3.jar:?]
	at org.asynchttpclient.netty.request.NettyRequestSender.sendRequestWithCertainForceConnect(NettyRequestSender.java:142) ~[async-http-client-2.5.3.jar:?]
	at org.asynchttpclient.netty.request.NettyRequestSender.sendRequest(NettyRequestSender.java:113) ~[async-http-client-2.5.3.jar:?]
	at org.asynchttpclient.DefaultAsyncHttpClient.execute(DefaultAsyncHttpClient.java:241) ~[async-http-client-2.5.3.jar:?]
	at org.asynchttpclient.DefaultAsyncHttpClient.executeRequest(DefaultAsyncHttpClient.java:210) ~[async-http-client-2.5.3.jar:?]
	at org.asynchttpclient.DefaultAsyncHttpClient.executeRequest(DefaultAsyncHttpClient.java:231) ~[async-http-client-2.5.3.jar:?]
	at org.asynchttpclient.DefaultAsyncHttpClient.executeRequest(DefaultAsyncHttpClient.java:236) ~[async-http-client-2.5.3.jar:?]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread.send(HttpPostEmitter.java:754) ~[druid-core-0.20.1.jar:0.20.1]
	... 10 more
2021-05-10T12:39:42,300 ERROR [HttpPostEmitter-1] org.apache.druid.java.util.emitter.core.HttpPostEmitter - Failed to send events to url[http://druid_exporter:8080/druid]
java.util.concurrent.ExecutionException: java.net.UnknownHostException: druid_exporter
	at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357) ~[?:1.8.0_275]
	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908) ~[?:1.8.0_275]
	at org.asynchttpclient.netty.NettyResponseFuture.get(NettyResponseFuture.java:202) ~[async-http-client-2.5.3.jar:?]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread.send(HttpPostEmitter.java:759) ~[druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread.access$1900(HttpPostEmitter.java:464) ~[druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread$1.perform(HttpPostEmitter.java:672) ~[druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread$1.perform(HttpPostEmitter.java:668) ~[druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.common.RetryUtils.retry(RetryUtils.java:87) ~[druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.common.RetryUtils.retry(RetryUtils.java:115) ~[druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.common.RetryUtils.retry(RetryUtils.java:105) ~[druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread.sendWithRetries(HttpPostEmitter.java:666) [druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread.emit(HttpPostEmitter.java:574) [druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread.emitBatches(HttpPostEmitter.java:550) [druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread.run(HttpPostEmitter.java:503) [druid-core-0.20.1.jar:0.20.1]
Caused by: java.net.UnknownHostException: druid_exporter
	at java.net.InetAddress.getAllByName0(InetAddress.java:1281) ~[?:1.8.0_275]
	at java.net.InetAddress.getAllByName(InetAddress.java:1193) ~[?:1.8.0_275]
	at java.net.InetAddress.getAllByName(InetAddress.java:1127) ~[?:1.8.0_275]
	at io.netty.util.internal.SocketUtils$9.run(SocketUtils.java:169) ~[netty-common-4.1.48.Final.jar:4.1.48.Final]
	at io.netty.util.internal.SocketUtils$9.run(SocketUtils.java:166) ~[netty-common-4.1.48.Final.jar:4.1.48.Final]
	at java.security.AccessController.doPrivileged(Native Method) ~[?:1.8.0_275]
	at io.netty.util.internal.SocketUtils.allAddressesByName(SocketUtils.java:166) ~[netty-common-4.1.48.Final.jar:4.1.48.Final]
	at io.netty.resolver.DefaultNameResolver.doResolveAll(DefaultNameResolver.java:50) ~[netty-resolver-4.1.48.Final.jar:4.1.48.Final]
	at io.netty.resolver.SimpleNameResolver.resolveAll(SimpleNameResolver.java:79) ~[netty-resolver-4.1.48.Final.jar:4.1.48.Final]
	at io.netty.resolver.SimpleNameResolver.resolveAll(SimpleNameResolver.java:71) ~[netty-resolver-4.1.48.Final.jar:4.1.48.Final]
	at org.asynchttpclient.resolver.RequestHostnameResolver.resolve(RequestHostnameResolver.java:50) ~[async-http-client-2.5.3.jar:?]
	at org.asynchttpclient.netty.request.NettyRequestSender.resolveAddresses(NettyRequestSender.java:357) ~[async-http-client-2.5.3.jar:?]
	at org.asynchttpclient.netty.request.NettyRequestSender.sendRequestWithNewChannel(NettyRequestSender.java:300) ~[async-http-client-2.5.3.jar:?]
	at org.asynchttpclient.netty.request.NettyRequestSender.sendRequestWithCertainForceConnect(NettyRequestSender.java:142) ~[async-http-client-2.5.3.jar:?]
	at org.asynchttpclient.netty.request.NettyRequestSender.sendRequest(NettyRequestSender.java:113) ~[async-http-client-2.5.3.jar:?]
	at org.asynchttpclient.DefaultAsyncHttpClient.execute(DefaultAsyncHttpClient.java:241) ~[async-http-client-2.5.3.jar:?]
	at org.asynchttpclient.DefaultAsyncHttpClient.executeRequest(DefaultAsyncHttpClient.java:210) ~[async-http-client-2.5.3.jar:?]
	at org.asynchttpclient.DefaultAsyncHttpClient.executeRequest(DefaultAsyncHttpClient.java:231) ~[async-http-client-2.5.3.jar:?]
	at org.asynchttpclient.DefaultAsyncHttpClient.executeRequest(DefaultAsyncHttpClient.java:236) ~[async-http-client-2.5.3.jar:?]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread.send(HttpPostEmitter.java:754) ~[druid-core-0.20.1.jar:0.20.1]
	... 10 more
2021-05-10T12:39:42,306 WARN [HttpPostEmitter-1] org.apache.druid.java.util.common.RetryUtils - Retrying (1 of 2) in 992ms.
java.util.concurrent.ExecutionException: java.net.UnknownHostException: druid_exporter
	at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357) ~[?:1.8.0_275]
	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908) ~[?:1.8.0_275]
	at org.asynchttpclient.netty.NettyResponseFuture.get(NettyResponseFuture.java:202) ~[async-http-client-2.5.3.jar:?]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread.send(HttpPostEmitter.java:759) ~[druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread.access$1900(HttpPostEmitter.java:464) ~[druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread$1.perform(HttpPostEmitter.java:672) ~[druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread$1.perform(HttpPostEmitter.java:668) ~[druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.common.RetryUtils.retry(RetryUtils.java:87) [druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.common.RetryUtils.retry(RetryUtils.java:115) [druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.common.RetryUtils.retry(RetryUtils.java:105) [druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread.sendWithRetries(HttpPostEmitter.java:666) [druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread.tryEmitOneFailedBuffer(HttpPostEmitter.java:639) [druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread.run(HttpPostEmitter.java:504) [druid-core-0.20.1.jar:0.20.1]
Caused by: java.net.UnknownHostException: druid_exporter
	at java.net.InetAddress.getAllByName0(InetAddress.java:1281) ~[?:1.8.0_275]
	at java.net.InetAddress.getAllByName(InetAddress.java:1193) ~[?:1.8.0_275]
	at java.net.InetAddress.getAllByName(InetAddress.java:1127) ~[?:1.8.0_275]
	at io.netty.util.internal.SocketUtils$9.run(SocketUtils.java:169) ~[netty-common-4.1.48.Final.jar:4.1.48.Final]
	at io.netty.util.internal.SocketUtils$9.run(SocketUtils.java:166) ~[netty-common-4.1.48.Final.jar:4.1.48.Final]
	at java.security.AccessController.doPrivileged(Native Method) ~[?:1.8.0_275]
	at io.netty.util.internal.SocketUtils.allAddressesByName(SocketUtils.java:166) ~[netty-common-4.1.48.Final.jar:4.1.48.Final]
	at io.netty.resolver.DefaultNameResolver.doResolveAll(DefaultNameResolver.java:50) ~[netty-resolver-4.1.48.Final.jar:4.1.48.Final]
	at io.netty.resolver.SimpleNameResolver.resolveAll(SimpleNameResolver.java:79) ~[netty-resolver-4.1.48.Final.jar:4.1.48.Final]
	at io.netty.resolver.SimpleNameResolver.resolveAll(SimpleNameResolver.java:71) ~[netty-resolver-4.1.48.Final.jar:4.1.48.Final]
	at org.asynchttpclient.resolver.RequestHostnameResolver.resolve(RequestHostnameResolver.java:50) ~[async-http-client-2.5.3.jar:?]
	at org.asynchttpclient.netty.request.NettyRequestSender.resolveAddresses(NettyRequestSender.java:357) ~[async-http-client-2.5.3.jar:?]
	at org.asynchttpclient.netty.request.NettyRequestSender.sendRequestWithNewChannel(NettyRequestSender.java:300) ~[async-http-client-2.5.3.jar:?]
	at org.asynchttpclient.netty.request.NettyRequestSender.sendRequestWithCertainForceConnect(NettyRequestSender.java:142) ~[async-http-client-2.5.3.jar:?]
	at org.asynchttpclient.netty.request.NettyRequestSender.sendRequest(NettyRequestSender.java:113) ~[async-http-client-2.5.3.jar:?]
	at org.asynchttpclient.DefaultAsyncHttpClient.execute(DefaultAsyncHttpClient.java:241) ~[async-http-client-2.5.3.jar:?]
	at org.asynchttpclient.DefaultAsyncHttpClient.executeRequest(DefaultAsyncHttpClient.java:210) ~[async-http-client-2.5.3.jar:?]
	at org.asynchttpclient.DefaultAsyncHttpClient.executeRequest(DefaultAsyncHttpClient.java:231) ~[async-http-client-2.5.3.jar:?]
	at org.asynchttpclient.DefaultAsyncHttpClient.executeRequest(DefaultAsyncHttpClient.java:236) ~[async-http-client-2.5.3.jar:?]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread.send(HttpPostEmitter.java:754) ~[druid-core-0.20.1.jar:0.20.1]
	... 9 more
2021-05-10T12:39:42,307 INFO [Curator-Framework-0] org.apache.curator.framework.imps.CuratorFrameworkImpl - backgroundOperationsLoop exiting
2021-05-10T12:39:42,308 WARN [HttpPostEmitter-1] org.apache.druid.java.util.common.RetryUtils - Retrying (1 of 2) in 933ms.
java.util.concurrent.ExecutionException: java.net.UnknownHostException: druid_exporter
	at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357) ~[?:1.8.0_275]
	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908) ~[?:1.8.0_275]
	at org.asynchttpclient.netty.NettyResponseFuture.get(NettyResponseFuture.java:202) ~[async-http-client-2.5.3.jar:?]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread.send(HttpPostEmitter.java:759) ~[druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread.access$1900(HttpPostEmitter.java:464) ~[druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread$1.perform(HttpPostEmitter.java:672) ~[druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread$1.perform(HttpPostEmitter.java:668) ~[druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.common.RetryUtils.retry(RetryUtils.java:87) [druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.common.RetryUtils.retry(RetryUtils.java:115) [druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.common.RetryUtils.retry(RetryUtils.java:105) [druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread.sendWithRetries(HttpPostEmitter.java:666) [druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread.tryEmitAndDrainAllFailedBuffers(HttpPostEmitter.java:654) [druid-core-0.20.1.jar:0.20.1]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread.run(HttpPostEmitter.java:507) [druid-core-0.20.1.jar:0.20.1]
Caused by: java.net.UnknownHostException: druid_exporter
	at java.net.InetAddress.getAllByName0(InetAddress.java:1281) ~[?:1.8.0_275]
	at java.net.InetAddress.getAllByName(InetAddress.java:1193) ~[?:1.8.0_275]
	at java.net.InetAddress.getAllByName(InetAddress.java:1127) ~[?:1.8.0_275]
	at io.netty.util.internal.SocketUtils$9.run(SocketUtils.java:169) ~[netty-common-4.1.48.Final.jar:4.1.48.Final]
	at io.netty.util.internal.SocketUtils$9.run(SocketUtils.java:166) ~[netty-common-4.1.48.Final.jar:4.1.48.Final]
	at java.security.AccessController.doPrivileged(Native Method) ~[?:1.8.0_275]
	at io.netty.util.internal.SocketUtils.allAddressesByName(SocketUtils.java:166) ~[netty-common-4.1.48.Final.jar:4.1.48.Final]
	at io.netty.resolver.DefaultNameResolver.doResolveAll(DefaultNameResolver.java:50) ~[netty-resolver-4.1.48.Final.jar:4.1.48.Final]
	at io.netty.resolver.SimpleNameResolver.resolveAll(SimpleNameResolver.java:79) ~[netty-resolver-4.1.48.Final.jar:4.1.48.Final]
	at io.netty.resolver.SimpleNameResolver.resolveAll(SimpleNameResolver.java:71) ~[netty-resolver-4.1.48.Final.jar:4.1.48.Final]
	at org.asynchttpclient.resolver.RequestHostnameResolver.resolve(RequestHostnameResolver.java:50) ~[async-http-client-2.5.3.jar:?]
	at org.asynchttpclient.netty.request.NettyRequestSender.resolveAddresses(NettyRequestSender.java:357) ~[async-http-client-2.5.3.jar:?]
	at org.asynchttpclient.netty.request.NettyRequestSender.sendRequestWithNewChannel(NettyRequestSender.java:300) ~[async-http-client-2.5.3.jar:?]
	at org.asynchttpclient.netty.request.NettyRequestSender.sendRequestWithCertainForceConnect(NettyRequestSender.java:142) ~[async-http-client-2.5.3.jar:?]
	at org.asynchttpclient.netty.request.NettyRequestSender.sendRequest(NettyRequestSender.java:113) ~[async-http-client-2.5.3.jar:?]
	at org.asynchttpclient.DefaultAsyncHttpClient.execute(DefaultAsyncHttpClient.java:241) ~[async-http-client-2.5.3.jar:?]
	at org.asynchttpclient.DefaultAsyncHttpClient.executeRequest(DefaultAsyncHttpClient.java:210) ~[async-http-client-2.5.3.jar:?]
	at org.asynchttpclient.DefaultAsyncHttpClient.executeRequest(DefaultAsyncHttpClient.java:231) ~[async-http-client-2.5.3.jar:?]
	at org.asynchttpclient.DefaultAsyncHttpClient.executeRequest(DefaultAsyncHttpClient.java:236) ~[async-http-client-2.5.3.jar:?]
	at org.apache.druid.java.util.emitter.core.HttpPostEmitter$EmittingThread.send(HttpPostEmitter.java:754) ~[druid-core-0.20.1.jar:0.20.1]
	... 9 more
2021-05-10T12:39:42,312 INFO [Thread-50] org.apache.zookeeper.ZooKeeper - Session: 0x1015c6238fa0045 closed
2021-05-10T12:39:42,312 INFO [Thread-50] org.apache.druid.java.util.common.lifecycle.Lifecycle$CloseableHandler - Closing object[org.asynchttpclient.DefaultAsyncHttpClient@61b8e632]
2021-05-10T12:39:42,313 INFO [main-EventThread] org.apache.zookeeper.ClientCnxn - EventThread shut down for session: 0x1015c6238fa0045
2021-05-10T12:39:42,318 INFO [Thread-50] org.apache.druid.java.util.common.lifecycle.Lifecycle - Stopping lifecycle [module] stage [INIT]