Skip to content

Instantly share code, notes, and snippets.

@frcake

frcake/log.txt

Created March 21, 2019 13:55
Show Gist options
  • Save frcake/a0887ccdf483e3e9319928c19cca04c0 to your computer and use it in GitHub Desktop.
Save frcake/a0887ccdf483e3e9319928c19cca04c0 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
log.txt
2019-03-21T13:26:26,574 INFO [main] io.druid.guice.PropertiesModule - Loading properties from common.runtime.properties
2019-03-21T13:26:26,579 INFO [main] io.druid.guice.PropertiesModule - Loading properties from runtime.properties
2019-03-21T13:26:26,642 INFO [main] org.hibernate.validator.internal.util.Version - HV000001: Hibernate Validator 5.1.3.Final
2019-03-21T13:26:27,558 INFO [main] io.druid.guice.JsonConfigurator - Loaded class[class io.druid.guice.ExtensionsConfig] from props[druid.extensions.] as [ExtensionsConfig{searchCurrentClassloader=true, directory='extensions', hadoopDependenciesDir='hadoop-dependencies', hadoopContainerDruidClasspath='null', addExtensionsToHadoopContainer=false, loadList=[mysql-metadata-storage, druid-kafka-indexing-service, statsd-emitter]}]
2019-03-21T13:26:27,660 INFO [main] io.druid.initialization.Initialization - Loading extension [mysql-metadata-storage] for class [interface io.druid.cli.CliCommandCreator]
2019-03-21T13:26:27,679 INFO [main] io.druid.initialization.Initialization - added URL[file:/opt/druid-0.12.3/extensions/mysql-metadata-storage/mysql-connector-java-5.1.38.jar]
2019-03-21T13:26:27,679 INFO [main] io.druid.initialization.Initialization - added URL[file:/opt/druid-0.12.3/extensions/mysql-metadata-storage/mysql-metadata-storage-0.12.3.jar]
2019-03-21T13:26:27,682 INFO [main] io.druid.initialization.Initialization - Loading extension [druid-kafka-indexing-service] for class [interface io.druid.cli.CliCommandCreator]
2019-03-21T13:26:27,683 INFO [main] io.druid.initialization.Initialization - added URL[file:/opt/druid-0.12.3/extensions/druid-kafka-indexing-service/snappy-java-1.1.2.6.jar]
2019-03-21T13:26:27,683 INFO [main] io.druid.initialization.Initialization - added URL[file:/opt/druid-0.12.3/extensions/druid-kafka-indexing-service/slf4j-api-1.6.4.jar]
2019-03-21T13:26:27,683 INFO [main] io.druid.initialization.Initialization - added URL[file:/opt/druid-0.12.3/extensions/druid-kafka-indexing-service/lz4-1.3.0.jar]
2019-03-21T13:26:27,684 INFO [main] io.druid.initialization.Initialization - added URL[file:/opt/druid-0.12.3/extensions/druid-kafka-indexing-service/kafka-clients-0.10.2.0.jar]
2019-03-21T13:26:27,684 INFO [main] io.druid.initialization.Initialization - added URL[file:/opt/druid-0.12.3/extensions/druid-kafka-indexing-service/druid-kafka-indexing-service-0.12.3.jar]
2019-03-21T13:26:27,686 INFO [main] io.druid.initialization.Initialization - Loading extension [statsd-emitter] for class [interface io.druid.cli.CliCommandCreator]
2019-03-21T13:26:27,686 INFO [main] io.druid.initialization.Initialization - added URL[file:/opt/druid-0.12.3/extensions/statsd-emitter/statsd-emitter-0.12.3.jar]
2019-03-21T13:26:27,686 INFO [main] io.druid.initialization.Initialization - added URL[file:/opt/druid-0.12.3/extensions/statsd-emitter/java-statsd-client-3.0.1.jar]
2019-03-21T13:26:27,827 INFO [main] io.druid.guice.JsonConfigurator - Loaded class[class io.druid.guice.ModulesConfig] from props[druid.modules.] as [ModulesConfig{excludeList=[]}]
2019-03-21T13:26:28,189 INFO [main] io.druid.initialization.Initialization - Loading extension [mysql-metadata-storage] for class [interface io.druid.initialization.DruidModule]
2019-03-21T13:26:28,193 INFO [main] io.druid.initialization.Initialization - Adding implementation [io.druid.metadata.storage.mysql.MySQLMetadataStorageModule] for class [interface io.druid.initialization.DruidModule] from local file system extension
2019-03-21T13:26:28,193 INFO [main] io.druid.initialization.Initialization - Loading extension [druid-kafka-indexing-service] for class [interface io.druid.initialization.DruidModule]
2019-03-21T13:26:28,195 INFO [main] io.druid.initialization.Initialization - Adding implementation [io.druid.indexing.kafka.KafkaIndexTaskModule] for class [interface io.druid.initialization.DruidModule] from local file system extension
2019-03-21T13:26:28,195 INFO [main] io.druid.initialization.Initialization - Loading extension [statsd-emitter] for class [interface io.druid.initialization.DruidModule]
2019-03-21T13:26:28,197 INFO [main] io.druid.initialization.Initialization - Adding implementation [io.druid.emitter.statsd.StatsDEmitterModule] for class [interface io.druid.initialization.DruidModule] from local file system extension
2019-03-21T13:26:29,513 INFO [main] io.druid.guice.JsonConfigurator - Loaded class[class io.druid.emitter.statsd.StatsDEmitterConfig] from props[druid.emitter.statsd.] as [io.druid.emitter.statsd.StatsDEmitterConfig@ccdadea]
2019-03-21T13:26:29,538 INFO [main] io.druid.emitter.statsd.DimensionConverter - Using default metric dimension and types
2019-03-21T13:26:29,585 INFO [main] io.druid.guice.JsonConfigurator - Loaded class[interface io.druid.server.security.Escalator] from props[druid.escalator.] as [io.druid.server.security.NoopEscalator@77c7ed8e]
2019-03-21T13:26:29,597 INFO [main] io.druid.guice.JsonConfigurator - Loaded class[class io.druid.curator.CuratorConfig] from props[druid.zk.service.] as [io.druid.curator.CuratorConfig@3f29e26]
2019-03-21T13:26:29,605 INFO [main] io.druid.guice.JsonConfigurator - Loaded class[class io.druid.curator.ExhibitorConfig] from props[druid.exhibitor.service.] as [io.druid.curator.ExhibitorConfig@d56aaa6]
2019-03-21T13:26:29,713 INFO [main] org.apache.curator.utils.Compatibility - Running in ZooKeeper 3.4.x compatibility mode
2019-03-21T13:26:29,716 WARN [main] org.apache.curator.retry.ExponentialBackoffRetry - maxRetries too large (30). Pinning to 29
2019-03-21T13:26:29,776 INFO [main] io.druid.guice.JsonConfigurator - Skipping druid.emitter.statsd.blankHolder property: one of it's prefixes is also used as a property key. Prefix: druid
2019-03-21T13:26:29,777 INFO [main] io.druid.guice.JsonConfigurator - Skipping druid.emitter.statsd.prefix property: one of it's prefixes is also used as a property key. Prefix: druid
2019-03-21T13:26:29,778 INFO [main] io.druid.guice.JsonConfigurator - Skipping druid.emitter.statsd.hostname property: one of it's prefixes is also used as a property key. Prefix: druid
2019-03-21T13:26:29,778 INFO [main] io.druid.guice.JsonConfigurator - Skipping druid.emitter.statsd.port property: one of it's prefixes is also used as a property key. Prefix: druid
2019-03-21T13:26:29,793 INFO [main] io.druid.guice.JsonConfigurator - Loaded class[class io.druid.server.DruidNode] from props[druid.] as [DruidNode{serviceName='druid/middleManager', host='staging-druid-01.ams01.voice-extranet.prv', port=-1, plaintextPort=8100, enablePlaintextPort=true, tlsPort=-1, enableTlsPort=false}]
2019-03-21T13:26:29,798 INFO [main] io.druid.guice.JsonConfigurator - Loaded class[class io.druid.server.initialization.ZkPathsConfig] from props[druid.zk.paths.] as [io.druid.server.initialization.ZkPathsConfig@22e2266d]
2019-03-21T13:26:29,812 INFO [main] io.druid.guice.JsonConfigurator - Loaded class[class io.druid.server.security.AuthConfig] from props[druid.auth.] as [AuthConfig{authenticatorChain=null, authorizers=null, allowUnauthenticatedHttpOptions=false}]
2019-03-21T13:26:29,908 INFO [main] io.druid.guice.JsonConfigurator - Loaded class[class io.druid.server.metrics.DruidMonitorSchedulerConfig] from props[druid.monitoring.] as [io.druid.server.metrics.DruidMonitorSchedulerConfig@1b4ae4e0]
2019-03-21T13:26:29,912 WARN [main] io.druid.server.metrics.MonitorsConfig - Deprecated Monitor class name [com.metamx.metrics.JvmMonitor] found, please use package io.druid.java.util.metrics instead of com.metamx.metrics
2019-03-21T13:26:29,916 INFO [main] io.druid.guice.JsonConfigurator - Loaded class[class io.druid.server.metrics.MonitorsConfig] from props[druid.monitoring.] as [MonitorsConfig{monitors=[class io.druid.java.util.metrics.JvmMonitor, class io.druid.client.cache.CacheMonitor]}]
2019-03-21T13:26:29,917 INFO [main] io.druid.server.emitter.EmitterModule - Underlying emitter for ServiceEmitter: io.druid.emitter.statsd.StatsDEmitter@2a685eba
2019-03-21T13:26:29,917 INFO [main] io.druid.server.emitter.EmitterModule - Extra service dimensions: {version=0.12.3}
2019-03-21T13:26:30,142 INFO [main] io.druid.guice.JsonConfigurator - Loaded class[class io.druid.server.initialization.CuratorDiscoveryConfig] from props[druid.discovery.curator.] as [io.druid.server.initialization.CuratorDiscoveryConfig@6ec7bce0]
2019-03-21T13:26:30,438 INFO [main] io.druid.guice.JsonConfigurator - Loaded class[class io.druid.server.initialization.ServerConfig] from props[druid.server.http.] as [io.druid.server.initialization.ServerConfig@215c3166]
2019-03-21T13:26:30,454 INFO [main] io.druid.guice.JsonConfigurator - Loaded class[class io.druid.query.lookup.LookupConfig] from props[druid.lookup.] as [LookupConfig{snapshotWorkingDir='', enableLookupSyncOnStartup=true, numLookupLoadingThreads=4, coordinatorFetchRetries=3, lookupStartRetries=3}]
2019-03-21T13:26:30,462 INFO [main] io.druid.guice.JsonConfigurator - Loaded class[class io.druid.guice.http.DruidHttpClientConfig] from props[druid.global.http.] as [io.druid.guice.http.DruidHttpClientConfig@1859e2a4]
2019-03-21T13:26:30,643 INFO [main] io.druid.guice.JsonConfigurator - Loaded class[class io.druid.client.coordinator.CoordinatorSelectorConfig] from props[druid.selectors.coordinator.] as [io.druid.client.coordinator.CoordinatorSelectorConfig@4acc5dff]
2019-03-21T13:26:30,718 INFO [main] io.druid.guice.JsonConfigurator - Loaded class[class io.druid.query.lookup.LookupListeningAnnouncerConfig] from props[druid.lookup.] as [ListeningAnnouncerConfig{listenersPath='/druid/listeners'}]
2019-03-21T13:26:31,243 INFO [main] io.druid.server.metrics.MetricsModule - Adding monitor[io.druid.java.util.metrics.JvmMonitor@67b355c8]
2019-03-21T13:26:31,253 INFO [main] io.druid.guice.JsonConfigurator - Loaded class[interface io.druid.client.cache.CacheProvider] from props[druid.cache.] as [io.druid.client.cache.CaffeineCacheProvider@3610f277]
2019-03-21T13:26:31,368 INFO [main] io.druid.server.metrics.MetricsModule - Adding monitor[io.druid.client.cache.CacheMonitor@38ee7a9d]
2019-03-21T13:26:31,370 INFO [main] io.druid.server.metrics.MetricsModule - Adding monitor[io.druid.query.ExecutorServiceMonitor@6ec63f8]
2019-03-21T13:26:31,370 INFO [main] io.druid.server.metrics.MetricsModule - Adding monitor[io.druid.server.initialization.jetty.JettyServerModule$JettyMonitor@479ac2cb]
2019-03-21T13:26:31,378 INFO [main] io.druid.guice.JsonConfigurator - Loaded class[class io.druid.server.log.StartupLoggingConfig] from props[druid.startup.logging.] as [io.druid.server.log.StartupLoggingConfig@1b0e9707]
2019-03-21T13:26:31,379 INFO [main] io.druid.cli.CliPeon - Starting up with processors[8], memory[697,303,040], maxMemory[1,908,932,608].
2019-03-21T13:26:31,380 INFO [main] io.druid.cli.CliPeon - * awt.toolkit: sun.awt.X11.XToolkit
2019-03-21T13:26:31,380 INFO [main] io.druid.cli.CliPeon - * druid.emitter: statsd
2019-03-21T13:26:31,381 INFO [main] io.druid.cli.CliPeon - * druid.emitter.statsd.blankHolder: "-"
2019-03-21T13:26:31,381 INFO [main] io.druid.cli.CliPeon - * druid.emitter.statsd.hostname: 10.104.232.205
2019-03-21T13:26:31,381 INFO [main] io.druid.cli.CliPeon - * druid.emitter.statsd.includeHost: False
2019-03-21T13:26:31,381 INFO [main] io.druid.cli.CliPeon - * druid.emitter.statsd.port: 8125
2019-03-21T13:26:31,381 INFO [main] io.druid.cli.CliPeon - * druid.emitter.statsd.prefix: "druid.voice-extranet.staging."
2019-03-21T13:26:31,381 INFO [main] io.druid.cli.CliPeon - * druid.extensions.loadList: ["mysql-metadata-storage","druid-kafka-indexing-service","statsd-emitter"]
2019-03-21T13:26:31,381 INFO [main] io.druid.cli.CliPeon - * druid.host: staging-druid-01.ams01.voice-extranet.prv
2019-03-21T13:26:31,382 INFO [main] io.druid.cli.CliPeon - * druid.indexer.fork.property.druid.processing.buffer.sizeBytes: 256000000
2019-03-21T13:26:31,382 INFO [main] io.druid.cli.CliPeon - * druid.indexer.fork.property.druid.processing.numThreads: 2
2019-03-21T13:26:31,382 INFO [main] io.druid.cli.CliPeon - * druid.indexer.logs.directory: /data/druid/indexing-logs
2019-03-21T13:26:31,382 INFO [main] io.druid.cli.CliPeon - * druid.indexer.logs.kill.durationToRetain: 3600000
2019-03-21T13:26:31,382 INFO [main] io.druid.cli.CliPeon - * druid.indexer.logs.kill.enabled: true
2019-03-21T13:26:31,382 INFO [main] io.druid.cli.CliPeon - * druid.indexer.logs.type: file
2019-03-21T13:26:31,382 INFO [main] io.druid.cli.CliPeon - * druid.indexer.runner.javaOpts: -server -Xmx2g -Duser.timezone=UTC -Dfile.encoding=UTF-8 -Djava.util.logging.manager=org.apache.logging.log4j.jul.LogManager
2019-03-21T13:26:31,383 INFO [main] io.druid.cli.CliPeon - * druid.indexer.task.baseTaskDir: /data/druid/task
2019-03-21T13:26:31,383 INFO [main] io.druid.cli.CliPeon - * druid.indexing.doubleStorage: double
2019-03-21T13:26:31,383 INFO [main] io.druid.cli.CliPeon - * druid.metadata.storage.connector.connectURI: jdbc:mysql://127.0.0.1:3306/druid_stag_db
2019-03-21T13:26:31,383 INFO [main] io.druid.cli.CliPeon - * druid.metadata.storage.connector.password: <masked>
2019-03-21T13:26:31,383 INFO [main] io.druid.cli.CliPeon - * druid.metadata.storage.connector.user: druid_stag
2019-03-21T13:26:31,383 INFO [main] io.druid.cli.CliPeon - * druid.metadata.storage.type: mysql
2019-03-21T13:26:31,383 INFO [main] io.druid.cli.CliPeon - * druid.metrics.emitter.dimension.dataSource: unrated-cdr-slim-rollup-large-new
2019-03-21T13:26:31,384 INFO [main] io.druid.cli.CliPeon - * druid.metrics.emitter.dimension.taskId: index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea_mgffnnmc
2019-03-21T13:26:31,384 INFO [main] io.druid.cli.CliPeon - * druid.monitoring.emissionPeriod: PT1M
2019-03-21T13:26:31,384 INFO [main] io.druid.cli.CliPeon - * druid.monitoring.monitors: ["com.metamx.metrics.JvmMonitor","io.druid.client.cache.CacheMonitor"]
2019-03-21T13:26:31,384 INFO [main] io.druid.cli.CliPeon - * druid.port: 8100
2019-03-21T13:26:31,384 INFO [main] io.druid.cli.CliPeon - * druid.processing.buffer.sizeBytes: 256000000
2019-03-21T13:26:31,384 INFO [main] io.druid.cli.CliPeon - * druid.processing.numThreads: 2
2019-03-21T13:26:31,384 INFO [main] io.druid.cli.CliPeon - * druid.selectors.coordinator.serviceName: druid/coordinator
2019-03-21T13:26:31,385 INFO [main] io.druid.cli.CliPeon - * druid.selectors.indexing.serviceName: druid/overlord
2019-03-21T13:26:31,385 INFO [main] io.druid.cli.CliPeon - * druid.server.http.numThreads: 9
2019-03-21T13:26:31,385 INFO [main] io.druid.cli.CliPeon - * druid.service: druid/middleManager
2019-03-21T13:26:31,385 INFO [main] io.druid.cli.CliPeon - * druid.startup.logging.logProperties: true
2019-03-21T13:26:31,385 INFO [main] io.druid.cli.CliPeon - * druid.storage.storageDirectory: /data/druid/segments
2019-03-21T13:26:31,385 INFO [main] io.druid.cli.CliPeon - * druid.storage.type: local
2019-03-21T13:26:31,385 INFO [main] io.druid.cli.CliPeon - * druid.tlsPort: -1
2019-03-21T13:26:31,385 INFO [main] io.druid.cli.CliPeon - * druid.worker.capacity: 3
2019-03-21T13:26:31,386 INFO [main] io.druid.cli.CliPeon - * druid.zk.paths.base: /druid
2019-03-21T13:26:31,386 INFO [main] io.druid.cli.CliPeon - * druid.zk.service.host: 127.0.0.1
2019-03-21T13:26:31,386 INFO [main] io.druid.cli.CliPeon - * file.encoding: UTF-8
2019-03-21T13:26:31,386 INFO [main] io.druid.cli.CliPeon - * file.encoding.pkg: sun.io
2019-03-21T13:26:31,386 INFO [main] io.druid.cli.CliPeon - * file.separator: /
2019-03-21T13:26:31,386 INFO [main] io.druid.cli.CliPeon - * java.awt.graphicsenv: sun.awt.X11GraphicsEnvironment
2019-03-21T13:26:31,386 INFO [main] io.druid.cli.CliPeon - * java.awt.printerjob: sun.print.PSPrinterJob
2019-03-21T13:26:31,387 INFO [main] io.druid.cli.CliPeon - * java.class.path: lib/javax.servlet-api-3.1.0.jar:lib/jetty-util-9.3.19.v20170502.jar:lib/jetty-http-9.3.19.v20170502.jar:lib/netty-codec-dns-2.0.37.jar:lib/jackson-databind-2.4.6.jar:lib/druid-console-0.0.2.jar:lib/javax.el-3.0.0.jar:lib/async-http-client-2.0.37.jar:lib/RoaringBitmap-0.5.18.jar:lib/bcprov-jdk15on-1.52.jar:lib/maven-model-builder-3.1.1.jar:lib/spymemcached-2.12.3.jar:lib/jackson-jaxrs-base-2.4.6.jar:lib/commons-codec-1.7.jar:lib/log4j-jul-2.5.jar:lib/activation-1.1.1.jar:lib/slf4j-api-1.6.4.jar:lib/guice-multibindings-4.1.0.jar:lib/antlr4-runtime-4.5.1.jar:lib/aws-java-sdk-core-1.10.77.jar:lib/commons-io-2.5.jar:lib/avatica-server-1.10.0.jar:lib/extendedset-0.12.3.jar:lib/maven-settings-builder-3.1.1.jar:lib/jetty-security-9.3.19.v20170502.jar:lib/avatica-core-1.10.0.jar:lib/avatica-metrics-1.10.0.jar:lib/jline-0.9.94.jar:lib/commons-pool-1.6.jar:lib/httpcore-4.4.3.jar:lib/jetty-server-9.3.19.v20170502.jar:lib/aether-connector-okhttp-0.0.9.jar:lib/javax.inject-1.jar:lib/netty-3.10.6.Final.jar:lib/jetty-client-9.3.19.v20170502.jar:lib/fastutil-8.1.0.jar:lib/lz4-1.3.0.jar:lib/log4j-1.2-api-2.5.jar:lib/mapdb-1.0.8.jar:lib/commons-dbcp-1.4.jar:lib/opencsv-2.3.jar:lib/jackson-jq-0.0.7.jar:lib/commons-cli-1.2.jar:lib/derby-10.11.1.1.jar:lib/jboss-logging-3.1.3.GA.jar:lib/reactive-streams-1.0.0.jar:lib/guava-16.0.1.jar:lib/jsr311-api-1.1.1.jar:lib/log4j-core-2.5.jar:lib/commons-logging-1.1.1.jar:lib/commons-pool2-2.2.jar:lib/joni-2.1.11.jar:lib/protobuf-java-3.1.0.jar:lib/maven-model-3.1.1.jar:lib/curator-recipes-4.0.0.jar:lib/druid-server-0.12.3.jar:lib/jackson-jaxrs-json-provider-2.4.6.jar:lib/jackson-annotations-2.4.6.jar:lib/aether-api-0.9.0.M2.jar:lib/maven-settings-3.1.1.jar:lib/jsr305-2.0.1.jar:lib/jetty-io-9.3.19.v20170502.jar:lib/curator-x-discovery-4.0.0.jar:lib/okhttp-1.0.2.jar:lib/netty-buffer-4.0.52.Final.jar:lib/jersey-server-1.19.3.jar:lib/aws-java-sdk-ec2-1.10.77.jar:lib/commons-lang3-3.2.jar:lib/jetty-servlet-9.3.19.v20170502.jar:lib/aether-impl-0.9.0.M2.jar:lib/commons-compiler-2.7.6.jar:lib/druid-services-0.12.3.jar:lib/netty-codec-4.0.52.Final.jar:lib/httpclient-4.5.1.jar:lib/derbyclient-10.11.1.1.jar:lib/plexus-interpolation-1.19.jar:lib/commons-math3-3.6.1.jar:lib/jackson-jaxrs-smile-provider-2.4.6.jar:lib/druid-api-0.12.3.jar:lib/druid-aws-common-0.12.3.jar:lib/jersey-servlet-1.19.3.jar:lib/jackson-mapper-asl-1.9.13.jar:lib/icu4j-54.1.1.jar:lib/druid-processing-0.12.3.jar:lib/plexus-utils-3.0.15.jar:lib/json-path-2.1.0.jar:lib/aether-util-0.9.0.M2.jar:lib/jackson-dataformat-smile-2.4.6.jar:lib/netty-resolver-dns-2.0.37.jar:lib/netty-common-4.0.52.Final.jar:lib/netty-all-4.0.52.Final.jar:lib/tesla-aether-0.0.5.jar:lib/aether-spi-0.9.0.M2.jar:lib/jetty-continuation-9.3.19.v20170502.jar:lib/commons-dbcp2-2.0.1.jar:lib/config-magic-0.9.jar:lib/hibernate-validator-5.1.3.Final.jar:lib/netty-transport-4.0.52.Final.jar:lib/aether-connector-file-0.9.0.M2.jar:lib/jackson-core-asl-1.9.13.jar:lib/jackson-module-jaxb-annotations-2.4.6.jar:lib/async-http-client-netty-utils-2.0.37.jar:lib/jackson-core-2.4.6.jar:lib/zookeeper-3.4.10.jar:lib/aopalliance-1.0.jar:lib/calcite-core-1.15.0.jar:lib/caffeine-2.5.5.jar:lib/validation-api-1.1.0.Final.jar:lib/jetty-servlets-9.3.19.v20170502.jar:lib/asm-commons-5.2.jar:lib/netty-resolver-2.0.37.jar:lib/jvm-attach-api-1.2.jar:lib/log4j-api-2.5.jar:lib/java-util-0.12.3.jar:lib/guice-servlet-4.1.0.jar:lib/java-xmlbuilder-1.1.jar:lib/maven-aether-provider-3.1.1.jar:lib/base64-2.3.8.jar:lib/jackson-dataformat-cbor-2.5.3.jar:lib/jcl-over-slf4j-1.7.12.jar:lib/netty-codec-http-4.0.52.Final.jar:lib/druid-indexing-service-0.12.3.jar:lib/compress-lzf-1.0.4.jar:lib/curator-client-4.0.0.jar:lib/jersey-guice-1.19.3.jar:lib/jersey-core-1.19.3.jar:lib/druid-indexing-hadoop-0.12.3.jar:lib/derbynet-10.11.1.1.jar:lib/asm-tree-5.2.jar:lib/maxminddb-0.2.0.jar:lib/guice-4.1.0.jar:lib/log4j-slf4j-impl-2.5.jar:lib/netty-transport-native-epoll-4.0.52.Final-linux-x86_64.jar:lib/netty-reactive-streams-1.0.8.jar:lib/disruptor-3.3.6.jar:lib/rhino-1.7R5.jar:lib/irc-api-1.0-0014.jar:lib/curator-framework-4.0.0.jar:lib/jdbi-2.63.1.jar:lib/jackson-datatype-guava-2.4.6.jar:lib/commons-lang-2.6.jar:lib/javax.el-api-3.0.0.jar:lib/druid-hll-0.12.3.jar:lib/joda-time-2.9.9.jar:lib/jetty-proxy-9.3.19.v20170502.jar:lib/druid-sql-0.12.3.jar:lib/jets3t-0.9.4.jar:lib/asm-5.2.jar:lib/druid-common-0.12.3.jar:lib/wagon-provider-api-2.4.jar:lib/geoip2-0.4.0.jar:lib/janino-2.7.6.jar:lib/maven-repository-metadata-3.1.1.jar:lib/classmate-1.0.0.jar:lib/esri-geometry-api-2.0.0.jar:lib/jcodings-1.0.13.jar:lib/netty-handler-4.0.52.Final.jar:lib/aggdesigner-algorithm-6.0.jar:lib/airline-0.7.jar:lib/jackson-datatype-joda-2.4.6.jar:lib/calcite-linq4j-1.15.0.jar:conf/druid/_common:conf/druid/middleManager
2019-03-21T13:26:31,387 INFO [main] io.druid.cli.CliPeon - * java.class.version: 52.0
2019-03-21T13:26:31,387 INFO [main] io.druid.cli.CliPeon - * java.endorsed.dirs: /usr/lib/jvm/java-1.8.0-openjdk-1.8.0.201.b09-2.el6_10.x86_64/jre/lib/endorsed
2019-03-21T13:26:31,387 INFO [main] io.druid.cli.CliPeon - * java.ext.dirs: /usr/lib/jvm/java-1.8.0-openjdk-1.8.0.201.b09-2.el6_10.x86_64/jre/lib/ext:/usr/java/packages/lib/ext
2019-03-21T13:26:31,387 INFO [main] io.druid.cli.CliPeon - * java.home: /usr/lib/jvm/java-1.8.0-openjdk-1.8.0.201.b09-2.el6_10.x86_64/jre
2019-03-21T13:26:31,387 INFO [main] io.druid.cli.CliPeon - * java.io.tmpdir: var/tmp
2019-03-21T13:26:31,387 INFO [main] io.druid.cli.CliPeon - * java.library.path: /usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib
2019-03-21T13:26:31,387 INFO [main] io.druid.cli.CliPeon - * java.runtime.name: OpenJDK Runtime Environment
2019-03-21T13:26:31,388 INFO [main] io.druid.cli.CliPeon - * java.runtime.version: 1.8.0_201-b09
2019-03-21T13:26:31,388 INFO [main] io.druid.cli.CliPeon - * java.specification.name: Java Platform API Specification
2019-03-21T13:26:31,388 INFO [main] io.druid.cli.CliPeon - * java.specification.vendor: Oracle Corporation
2019-03-21T13:26:31,388 INFO [main] io.druid.cli.CliPeon - * java.specification.version: 1.8
2019-03-21T13:26:31,388 INFO [main] io.druid.cli.CliPeon - * java.util.logging.manager: org.apache.logging.log4j.jul.LogManager
2019-03-21T13:26:31,388 INFO [main] io.druid.cli.CliPeon - * java.vendor: Oracle Corporation
2019-03-21T13:26:31,389 INFO [main] io.druid.cli.CliPeon - * java.vendor.url: http://java.oracle.com/
2019-03-21T13:26:31,389 INFO [main] io.druid.cli.CliPeon - * java.vendor.url.bug: http://bugreport.sun.com/bugreport/
2019-03-21T13:26:31,389 INFO [main] io.druid.cli.CliPeon - * java.version: 1.8.0_201
2019-03-21T13:26:31,389 INFO [main] io.druid.cli.CliPeon - * java.vm.info: mixed mode
2019-03-21T13:26:31,389 INFO [main] io.druid.cli.CliPeon - * java.vm.name: OpenJDK 64-Bit Server VM
2019-03-21T13:26:31,389 INFO [main] io.druid.cli.CliPeon - * java.vm.specification.name: Java Virtual Machine Specification
2019-03-21T13:26:31,389 INFO [main] io.druid.cli.CliPeon - * java.vm.specification.vendor: Oracle Corporation
2019-03-21T13:26:31,390 INFO [main] io.druid.cli.CliPeon - * java.vm.specification.version: 1.8
2019-03-21T13:26:31,390 INFO [main] io.druid.cli.CliPeon - * java.vm.vendor: Oracle Corporation
2019-03-21T13:26:31,390 INFO [main] io.druid.cli.CliPeon - * java.vm.version: 25.201-b09
2019-03-21T13:26:31,390 INFO [main] io.druid.cli.CliPeon - * line.separator:
2019-03-21T13:26:31,390 INFO [main] io.druid.cli.CliPeon - * log4j.shutdownCallbackRegistry: io.druid.common.config.Log4jShutdown
2019-03-21T13:26:31,390 INFO [main] io.druid.cli.CliPeon - * log4j.shutdownHookEnabled: true
2019-03-21T13:26:31,390 INFO [main] io.druid.cli.CliPeon - * os.arch: amd64
2019-03-21T13:26:31,391 INFO [main] io.druid.cli.CliPeon - * os.name: Linux
2019-03-21T13:26:31,391 INFO [main] io.druid.cli.CliPeon - * os.version: 2.6.32-696.13.2.el6.x86_64
2019-03-21T13:26:31,391 INFO [main] io.druid.cli.CliPeon - * path.separator: :
2019-03-21T13:26:31,391 INFO [main] io.druid.cli.CliPeon - * sun.arch.data.model: 64
2019-03-21T13:26:31,391 INFO [main] io.druid.cli.CliPeon - * sun.boot.class.path: /usr/lib/jvm/java-1.8.0-openjdk-1.8.0.201.b09-2.el6_10.x86_64/jre/lib/resources.jar:/usr/lib/jvm/java-1.8.0-openjdk-1.8.0.201.b09-2.el6_10.x86_64/jre/lib/rt.jar:/usr/lib/jvm/java-1.8.0-openjdk-1.8.0.201.b09-2.el6_10.x86_64/jre/lib/sunrsasign.jar:/usr/lib/jvm/java-1.8.0-openjdk-1.8.0.201.b09-2.el6_10.x86_64/jre/lib/jsse.jar:/usr/lib/jvm/java-1.8.0-openjdk-1.8.0.201.b09-2.el6_10.x86_64/jre/lib/jce.jar:/usr/lib/jvm/java-1.8.0-openjdk-1.8.0.201.b09-2.el6_10.x86_64/jre/lib/charsets.jar:/usr/lib/jvm/java-1.8.0-openjdk-1.8.0.201.b09-2.el6_10.x86_64/jre/lib/jfr.jar:/usr/lib/jvm/java-1.8.0-openjdk-1.8.0.201.b09-2.el6_10.x86_64/jre/classes
2019-03-21T13:26:31,391 INFO [main] io.druid.cli.CliPeon - * sun.boot.library.path: /usr/lib/jvm/java-1.8.0-openjdk-1.8.0.201.b09-2.el6_10.x86_64/jre/lib/amd64
2019-03-21T13:26:31,391 INFO [main] io.druid.cli.CliPeon - * sun.cpu.endian: little
2019-03-21T13:26:31,392 INFO [main] io.druid.cli.CliPeon - * sun.cpu.isalist:
2019-03-21T13:26:31,392 INFO [main] io.druid.cli.CliPeon - * sun.io.unicode.encoding: UnicodeLittle
2019-03-21T13:26:31,392 INFO [main] io.druid.cli.CliPeon - * sun.java.command: io.druid.cli.Main internal peon /data/druid/task/index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea_mgffnnmc/task.json /data/druid/task/index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea_mgffnnmc/3d640e86-5707-409a-9388-4b483e5f320a/status.json
2019-03-21T13:26:31,392 INFO [main] io.druid.cli.CliPeon - * sun.java.launcher: SUN_STANDARD
2019-03-21T13:26:31,392 INFO [main] io.druid.cli.CliPeon - * sun.jnu.encoding: UTF-8
2019-03-21T13:26:31,392 INFO [main] io.druid.cli.CliPeon - * sun.management.compiler: HotSpot 64-Bit Tiered Compilers
2019-03-21T13:26:31,392 INFO [main] io.druid.cli.CliPeon - * sun.os.patch.level: unknown
2019-03-21T13:26:31,392 INFO [main] io.druid.cli.CliPeon - * user.country: US
2019-03-21T13:26:31,393 INFO [main] io.druid.cli.CliPeon - * user.dir: /opt/druid-0.12.3
2019-03-21T13:26:31,393 INFO [main] io.druid.cli.CliPeon - * user.home: /home/druid
2019-03-21T13:26:31,393 INFO [main] io.druid.cli.CliPeon - * user.language: en
2019-03-21T13:26:31,393 INFO [main] io.druid.cli.CliPeon - * user.name: druid
2019-03-21T13:26:31,393 INFO [main] io.druid.cli.CliPeon - * user.timezone: UTC
2019-03-21T13:26:31,401 INFO [main] io.druid.guice.JsonConfigurator - Loaded class[class io.druid.indexing.common.config.TaskConfig] from props[druid.indexer.task.] as [io.druid.indexing.common.config.TaskConfig@17fede14]
2019-03-21T13:26:31,403 INFO [main] io.druid.guice.JsonConfigurator - Loaded class[class io.druid.client.indexing.IndexingServiceSelectorConfig] from props[druid.selectors.indexing.] as [io.druid.client.indexing.IndexingServiceSelectorConfig@24c8d8be]
2019-03-21T13:26:31,407 INFO [main] io.druid.guice.JsonConfigurator - Loaded class[class io.druid.indexing.common.RetryPolicyConfig] from props[druid.peon.taskActionClient.retry.] as [io.druid.indexing.common.RetryPolicyConfig@71370fec]
2019-03-21T13:26:31,409 INFO [main] io.druid.guice.JsonConfigurator - Loaded class[class io.druid.segment.loading.LocalDataSegmentPusherConfig] from props[druid.storage.] as [io.druid.segment.loading.LocalDataSegmentPusherConfig@50b0afd7]
2019-03-21T13:26:31,410 INFO [main] io.druid.segment.loading.LocalDataSegmentPusher - Configured local filesystem as deep storage
2019-03-21T13:26:31,415 INFO [main] io.druid.guice.JsonConfigurator - Loaded class[class io.druid.client.DruidServerConfig] from props[druid.server.] as [io.druid.client.DruidServerConfig@49f3ff41]
2019-03-21T13:26:31,420 INFO [main] io.druid.guice.JsonConfigurator - Loaded class[class io.druid.server.initialization.BatchDataSegmentAnnouncerConfig] from props[druid.announcer.] as [io.druid.server.initialization.BatchDataSegmentAnnouncerConfig@79eeff87]
2019-03-21T13:26:31,429 INFO [main] io.druid.guice.JsonConfigurator - Loaded class[interface io.druid.server.coordination.DataSegmentAnnouncerProvider] from props[druid.announcer.] as [io.druid.server.coordination.BatchDataSegmentAnnouncerProvider@481558ce]
2019-03-21T13:26:31,433 INFO [main] io.druid.guice.JsonConfigurator - Loaded class[class io.druid.segment.realtime.plumber.CoordinatorBasedSegmentHandoffNotifierConfig] from props[druid.segment.handoff.] as [io.druid.segment.realtime.plumber.CoordinatorBasedSegmentHandoffNotifierConfig@a6e4897]
2019-03-21T13:26:31,438 INFO [main] org.skife.config.ConfigurationObjectFactory - Assigning value [256000000] for [druid.processing.buffer.sizeBytes] on [io.druid.query.DruidProcessingConfig#intermediateComputeSizeBytes()]
2019-03-21T13:26:31,441 INFO [main] org.skife.config.ConfigurationObjectFactory - Using method itself for [druid.computation.buffer.poolCacheMaxCount, ${base_path}.buffer.poolCacheMaxCount] on [io.druid.query.DruidProcessingConfig#poolCacheMaxCount()]
2019-03-21T13:26:31,443 INFO [main] org.skife.config.ConfigurationObjectFactory - Using method itself for [${base_path}.fifo] on [io.druid.query.DruidProcessingConfig#isFifo()]
2019-03-21T13:26:31,443 INFO [main] org.skife.config.ConfigurationObjectFactory - Assigning value [2] for [druid.processing.numThreads] on [io.druid.query.DruidProcessingConfig#getNumThreadsConfigured()]
2019-03-21T13:26:31,444 INFO [main] org.skife.config.ConfigurationObjectFactory - Using method itself for [${base_path}.numMergeBuffers] on [io.druid.query.DruidProcessingConfig#getNumMergeBuffersConfigured()]
2019-03-21T13:26:31,444 INFO [main] org.skife.config.ConfigurationObjectFactory - Using method itself for [${base_path}.columnCache.sizeBytes] on [io.druid.query.DruidProcessingConfig#columnCacheSizeBytes()]
2019-03-21T13:26:31,444 INFO [main] org.skife.config.ConfigurationObjectFactory - Using method itself for [${base_path}.tmpDir] on [io.druid.query.DruidProcessingConfig#getTmpDir()]
2019-03-21T13:26:31,445 INFO [main] org.skife.config.ConfigurationObjectFactory - Assigning default value [processing-%s] for [${base_path}.formatString] on [io.druid.java.util.common.concurrent.ExecutorServiceConfig#getFormatString()]
2019-03-21T13:26:31,566 INFO [main] io.druid.guice.JsonConfigurator - Loaded class[interface io.druid.segment.writeout.SegmentWriteOutMediumFactory] from props[druid.peon.defaultSegmentWriteOutMediumFactory.] as [io.druid.segment.writeout.TmpFileSegmentWriteOutMediumFactory@4cb957b8]
2019-03-21T13:26:31,578 INFO [main] io.druid.guice.JsonConfigurator - Loaded class[class io.druid.client.cache.CacheConfig] from props[druid.realtime.cache.] as [io.druid.client.cache.CacheConfig@545b5ed0]
2019-03-21T13:26:31,591 INFO [main] io.druid.guice.JsonConfigurator - Loaded class[class io.druid.server.initialization.TLSServerConfig] from props[druid.server.https.] as [TLSServerConfig{keyStorePath='null', keyStoreType='null', certAlias='null', keyManagerFactoryAlgorithm='null', includeCipherSuites=null, excludeCipherSuites=null, includeProtocols=null, excludeProtocols=null}]
2019-03-21T13:26:31,614 INFO [main] org.eclipse.jetty.util.log - Logging initialized @6677ms
2019-03-21T13:26:31,636 INFO [main] io.druid.server.initialization.jetty.JettyServerModule - Creating http connector with port [8100]
2019-03-21T13:26:31,817 INFO [main] io.druid.guice.JsonConfigurator - Loaded class[class io.druid.query.search.SearchQueryConfig] from props[druid.query.search.] as [io.druid.query.search.SearchQueryConfig@3bb9ca38]
2019-03-21T13:26:31,826 INFO [main] io.druid.guice.JsonConfigurator - Loaded class[class io.druid.query.metadata.SegmentMetadataQueryConfig] from props[druid.query.segmentMetadata.] as [io.druid.query.metadata.SegmentMetadataQueryConfig@562919fe]
2019-03-21T13:26:31,833 INFO [main] io.druid.guice.JsonConfigurator - Loaded class[class io.druid.query.groupby.GroupByQueryConfig] from props[druid.query.groupBy.] as [GroupByQueryConfig{defaultStrategy='v2', singleThreaded=false, maxIntermediateRows=50000, maxResults=500000, bufferGrouperMaxSize=2147483647, bufferGrouperMaxLoadFactor=0.0, bufferGrouperInitialBuckets=0, maxMergingDictionarySize=100000000, maxOnDiskStorage=0, forcePushDownLimit=false, forceHashAggregation=false, intermediateCombineDegree=8, numParallelCombineThreads=1}]
2019-03-21T13:26:31,860 INFO [main] io.druid.offheap.OffheapBufferGenerator - Allocating new intermediate processing buffer[0] of size[256,000,000]
2019-03-21T13:26:32,490 INFO [main] io.druid.offheap.OffheapBufferGenerator - Allocating new intermediate processing buffer[1] of size[256,000,000]
2019-03-21T13:26:33,099 INFO [main] io.druid.offheap.OffheapBufferGenerator - Allocating new result merging buffer[0] of size[256,000,000]
2019-03-21T13:26:33,687 INFO [main] io.druid.offheap.OffheapBufferGenerator - Allocating new result merging buffer[1] of size[256,000,000]
2019-03-21T13:26:34,270 INFO [main] io.druid.guice.JsonConfigurator - Loaded class[class io.druid.query.scan.ScanQueryConfig] from props[druid.query.scan.] as [ScanQueryConfig{legacy=false}]
2019-03-21T13:26:34,272 INFO [main] io.druid.guice.JsonConfigurator - Loaded class[class io.druid.query.select.SelectQueryConfig] from props[druid.query.select.] as [io.druid.query.select.SelectQueryConfig@16e99306]
2019-03-21T13:26:34,275 INFO [main] io.druid.guice.JsonConfigurator - Loaded class[class io.druid.query.topn.TopNQueryConfig] from props[druid.query.topN.] as [io.druid.query.topn.TopNQueryConfig@4dfdfe7d]
2019-03-21T13:26:34,278 INFO [main] io.druid.guice.JsonConfigurator - Loaded class[interface io.druid.server.log.RequestLoggerProvider] from props[druid.request.logging.] as [io.druid.server.log.NoopRequestLoggerProvider@87d9a01]
2019-03-21T13:26:34,299 INFO [main] io.druid.curator.CuratorModule - Starting Curator
2019-03-21T13:26:34,299 INFO [main] org.apache.curator.framework.imps.CuratorFrameworkImpl - Starting
2019-03-21T13:26:34,313 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:zookeeper.version=3.4.10-39d3a4f269333c922ed3db283be479f9deacaa0f, built on 03/23/2017 10:13 GMT
2019-03-21T13:26:34,313 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:host.name=staging-druid-01.ams01.voice-extranet.prv
2019-03-21T13:26:34,313 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:java.version=1.8.0_201
2019-03-21T13:26:34,314 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:java.vendor=Oracle Corporation
2019-03-21T13:26:34,314 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:java.home=/usr/lib/jvm/java-1.8.0-openjdk-1.8.0.201.b09-2.el6_10.x86_64/jre
2019-03-21T13:26:34,314 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:java.class.path=lib/javax.servlet-api-3.1.0.jar:lib/jetty-util-9.3.19.v20170502.jar:lib/jetty-http-9.3.19.v20170502.jar:lib/netty-codec-dns-2.0.37.jar:lib/jackson-databind-2.4.6.jar:lib/druid-console-0.0.2.jar:lib/javax.el-3.0.0.jar:lib/async-http-client-2.0.37.jar:lib/RoaringBitmap-0.5.18.jar:lib/bcprov-jdk15on-1.52.jar:lib/maven-model-builder-3.1.1.jar:lib/spymemcached-2.12.3.jar:lib/jackson-jaxrs-base-2.4.6.jar:lib/commons-codec-1.7.jar:lib/log4j-jul-2.5.jar:lib/activation-1.1.1.jar:lib/slf4j-api-1.6.4.jar:lib/guice-multibindings-4.1.0.jar:lib/antlr4-runtime-4.5.1.jar:lib/aws-java-sdk-core-1.10.77.jar:lib/commons-io-2.5.jar:lib/avatica-server-1.10.0.jar:lib/extendedset-0.12.3.jar:lib/maven-settings-builder-3.1.1.jar:lib/jetty-security-9.3.19.v20170502.jar:lib/avatica-core-1.10.0.jar:lib/avatica-metrics-1.10.0.jar:lib/jline-0.9.94.jar:lib/commons-pool-1.6.jar:lib/httpcore-4.4.3.jar:lib/jetty-server-9.3.19.v20170502.jar:lib/aether-connector-okhttp-0.0.9.jar:lib/javax.inject-1.jar:lib/netty-3.10.6.Final.jar:lib/jetty-client-9.3.19.v20170502.jar:lib/fastutil-8.1.0.jar:lib/lz4-1.3.0.jar:lib/log4j-1.2-api-2.5.jar:lib/mapdb-1.0.8.jar:lib/commons-dbcp-1.4.jar:lib/opencsv-2.3.jar:lib/jackson-jq-0.0.7.jar:lib/commons-cli-1.2.jar:lib/derby-10.11.1.1.jar:lib/jboss-logging-3.1.3.GA.jar:lib/reactive-streams-1.0.0.jar:lib/guava-16.0.1.jar:lib/jsr311-api-1.1.1.jar:lib/log4j-core-2.5.jar:lib/commons-logging-1.1.1.jar:lib/commons-pool2-2.2.jar:lib/joni-2.1.11.jar:lib/protobuf-java-3.1.0.jar:lib/maven-model-3.1.1.jar:lib/curator-recipes-4.0.0.jar:lib/druid-server-0.12.3.jar:lib/jackson-jaxrs-json-provider-2.4.6.jar:lib/jackson-annotations-2.4.6.jar:lib/aether-api-0.9.0.M2.jar:lib/maven-settings-3.1.1.jar:lib/jsr305-2.0.1.jar:lib/jetty-io-9.3.19.v20170502.jar:lib/curator-x-discovery-4.0.0.jar:lib/okhttp-1.0.2.jar:lib/netty-buffer-4.0.52.Final.jar:lib/jersey-server-1.19.3.jar:lib/aws-java-sdk-ec2-1.10.77.jar:lib/commons-lang3-3.2.jar:lib/jetty-servlet-9.3.19.v20170502.jar:lib/aether-impl-0.9.0.M2.jar:lib/commons-compiler-2.7.6.jar:lib/druid-services-0.12.3.jar:lib/netty-codec-4.0.52.Final.jar:lib/httpclient-4.5.1.jar:lib/derbyclient-10.11.1.1.jar:lib/plexus-interpolation-1.19.jar:lib/commons-math3-3.6.1.jar:lib/jackson-jaxrs-smile-provider-2.4.6.jar:lib/druid-api-0.12.3.jar:lib/druid-aws-common-0.12.3.jar:lib/jersey-servlet-1.19.3.jar:lib/jackson-mapper-asl-1.9.13.jar:lib/icu4j-54.1.1.jar:lib/druid-processing-0.12.3.jar:lib/plexus-utils-3.0.15.jar:lib/json-path-2.1.0.jar:lib/aether-util-0.9.0.M2.jar:lib/jackson-dataformat-smile-2.4.6.jar:lib/netty-resolver-dns-2.0.37.jar:lib/netty-common-4.0.52.Final.jar:lib/netty-all-4.0.52.Final.jar:lib/tesla-aether-0.0.5.jar:lib/aether-spi-0.9.0.M2.jar:lib/jetty-continuation-9.3.19.v20170502.jar:lib/commons-dbcp2-2.0.1.jar:lib/config-magic-0.9.jar:lib/hibernate-validator-5.1.3.Final.jar:lib/netty-transport-4.0.52.Final.jar:lib/aether-connector-file-0.9.0.M2.jar:lib/jackson-core-asl-1.9.13.jar:lib/jackson-module-jaxb-annotations-2.4.6.jar:lib/async-http-client-netty-utils-2.0.37.jar:lib/jackson-core-2.4.6.jar:lib/zookeeper-3.4.10.jar:lib/aopalliance-1.0.jar:lib/calcite-core-1.15.0.jar:lib/caffeine-2.5.5.jar:lib/validation-api-1.1.0.Final.jar:lib/jetty-servlets-9.3.19.v20170502.jar:lib/asm-commons-5.2.jar:lib/netty-resolver-2.0.37.jar:lib/jvm-attach-api-1.2.jar:lib/log4j-api-2.5.jar:lib/java-util-0.12.3.jar:lib/guice-servlet-4.1.0.jar:lib/java-xmlbuilder-1.1.jar:lib/maven-aether-provider-3.1.1.jar:lib/base64-2.3.8.jar:lib/jackson-dataformat-cbor-2.5.3.jar:lib/jcl-over-slf4j-1.7.12.jar:lib/netty-codec-http-4.0.52.Final.jar:lib/druid-indexing-service-0.12.3.jar:lib/compress-lzf-1.0.4.jar:lib/curator-client-4.0.0.jar:lib/jersey-guice-1.19.3.jar:lib/jersey-core-1.19.3.jar:lib/druid-indexing-hadoop-0.12.3.jar:lib/derbynet-10.11.1.1.jar:lib/asm-tree-5.2.jar:lib/maxminddb-0.2.0.jar:lib/guice-4.1.0.jar:lib/log4j-slf4j-impl-2.5.jar:lib/netty-transport-native-epoll-4.0.52.Final-linux-x86_64.jar:lib/netty-reactive-streams-1.0.8.jar:lib/disruptor-3.3.6.jar:lib/rhino-1.7R5.jar:lib/irc-api-1.0-0014.jar:lib/curator-framework-4.0.0.jar:lib/jdbi-2.63.1.jar:lib/jackson-datatype-guava-2.4.6.jar:lib/commons-lang-2.6.jar:lib/javax.el-api-3.0.0.jar:lib/druid-hll-0.12.3.jar:lib/joda-time-2.9.9.jar:lib/jetty-proxy-9.3.19.v20170502.jar:lib/druid-sql-0.12.3.jar:lib/jets3t-0.9.4.jar:lib/asm-5.2.jar:lib/druid-common-0.12.3.jar:lib/wagon-provider-api-2.4.jar:lib/geoip2-0.4.0.jar:lib/janino-2.7.6.jar:lib/maven-repository-metadata-3.1.1.jar:lib/classmate-1.0.0.jar:lib/esri-geometry-api-2.0.0.jar:lib/jcodings-1.0.13.jar:lib/netty-handler-4.0.52.Final.jar:lib/aggdesigner-algorithm-6.0.jar:lib/airline-0.7.jar:lib/jackson-datatype-joda-2.4.6.jar:lib/calcite-linq4j-1.15.0.jar:conf/druid/_common:conf/druid/middleManager
2019-03-21T13:26:34,314 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:java.library.path=/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib
2019-03-21T13:26:34,314 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:java.io.tmpdir=var/tmp
2019-03-21T13:26:34,314 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:java.compiler=<NA>
2019-03-21T13:26:34,314 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:os.name=Linux
2019-03-21T13:26:34,314 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:os.arch=amd64
2019-03-21T13:26:34,314 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:os.version=2.6.32-696.13.2.el6.x86_64
2019-03-21T13:26:34,314 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:user.name=druid
2019-03-21T13:26:34,314 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:user.home=/home/druid
2019-03-21T13:26:34,315 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:user.dir=/opt/druid-0.12.3
2019-03-21T13:26:34,316 INFO [main] org.apache.zookeeper.ZooKeeper - Initiating client connection, connectString=127.0.0.1 sessionTimeout=30000 watcher=org.apache.curator.ConnectionState@55736cfe
2019-03-21T13:26:34,347 INFO [main] org.apache.curator.framework.imps.CuratorFrameworkImpl - Default schema
2019-03-21T13:26:34,348 INFO [main] io.druid.java.util.common.lifecycle.Lifecycle$AnnotationBasedHandler - Invoking start method[public void io.druid.initialization.Log4jShutterDownerModule$Log4jShutterDowner.start()] on object[io.druid.initialization.Log4jShutterDownerModule$Log4jShutterDowner@57e5396b].
2019-03-21T13:26:34,349 INFO [main] io.druid.java.util.common.lifecycle.Lifecycle$AnnotationBasedHandler - Invoking start method[public void io.druid.java.util.emitter.service.ServiceEmitter.start()] on object[ServiceEmitter{serviceDimensions={service=druid/middleManager, host=staging-druid-01.ams01.voice-extranet.prv:8100, version=0.12.3}, emitter=io.druid.emitter.statsd.StatsDEmitter@2a685eba}].
2019-03-21T13:26:34,349 INFO [main-SendThread(127.0.0.1:2181)] org.apache.zookeeper.ClientCnxn - Opening socket connection to server 127.0.0.1/127.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error)
2019-03-21T13:26:34,352 INFO [main] io.druid.java.util.common.lifecycle.Lifecycle$AnnotationBasedHandler - Invoking start method[public void io.druid.java.util.http.client.NettyHttpClient.start()] on object[io.druid.java.util.http.client.NettyHttpClient@6cbb175].
2019-03-21T13:26:34,352 INFO [main] io.druid.java.util.common.lifecycle.Lifecycle$AnnotationBasedHandler - Invoking start method[public void io.druid.curator.discovery.CuratorDruidNodeDiscoveryProvider.start()] on object[io.druid.curator.discovery.CuratorDruidNodeDiscoveryProvider@38fb50f8].
2019-03-21T13:26:34,352 INFO [main] io.druid.curator.discovery.CuratorDruidNodeDiscoveryProvider - starting
2019-03-21T13:26:34,353 INFO [main] io.druid.curator.discovery.CuratorDruidNodeDiscoveryProvider - started
2019-03-21T13:26:34,353 INFO [main] io.druid.java.util.common.lifecycle.Lifecycle$AnnotationBasedHandler - Invoking start method[public void io.druid.curator.discovery.ServerDiscoverySelector.start() throws java.lang.Exception] on object[io.druid.curator.discovery.ServerDiscoverySelector@608cd501].
2019-03-21T13:26:34,369 INFO [main-SendThread(127.0.0.1:2181)] org.apache.zookeeper.ClientCnxn - Socket connection established to 127.0.0.1/127.0.0.1:2181, initiating session
2019-03-21T13:26:34,379 INFO [main-SendThread(127.0.0.1:2181)] org.apache.zookeeper.ClientCnxn - Session establishment complete on server 127.0.0.1/127.0.0.1:2181, sessionid = 0x1699aed2dfc00a0, negotiated timeout = 30000
2019-03-21T13:26:34,390 INFO [main-EventThread] org.apache.curator.framework.state.ConnectionStateManager - State change: CONNECTED
2019-03-21T13:26:34,526 INFO [main] io.druid.java.util.common.lifecycle.Lifecycle$AnnotationBasedHandler - Invoking start method[public void io.druid.discovery.DruidLeaderClient.start()] on object[io.druid.discovery.DruidLeaderClient@7fe8c7db].
2019-03-21T13:26:34,528 INFO [main] io.druid.curator.discovery.CuratorDruidNodeDiscoveryProvider - Creating NodeTypeWatcher for nodeType [coordinator].
2019-03-21T13:26:34,532 INFO [main] io.druid.curator.discovery.CuratorDruidNodeDiscoveryProvider - Created NodeTypeWatcher for nodeType [coordinator].
2019-03-21T13:26:34,532 INFO [main] io.druid.discovery.DruidLeaderClient - Started.
2019-03-21T13:26:34,533 INFO [main] io.druid.java.util.common.lifecycle.Lifecycle$AnnotationBasedHandler - Invoking start method[public void io.druid.query.lookup.LookupReferencesManager.start()] on object[io.druid.query.lookup.LookupReferencesManager@149274cb].
2019-03-21T13:26:34,533 INFO [main] io.druid.query.lookup.LookupReferencesManager - LookupReferencesManager is starting.
2019-03-21T13:26:34,557 INFO [main] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8081
2019-03-21T13:26:34,569 INFO [NodeTypeWatcher[coordinator]] io.druid.curator.discovery.CuratorDruidNodeDiscoveryProvider$NodeTypeWatcher - Received event [CHILD_ADDED] for Node[coordinator:DiscoveryDruidNode{druidNode=DruidNode{serviceName='druid/coordinator', host='staging-druid-01.ams01.voice-extranet.prv', port=-1, plaintextPort=8081, enablePlaintextPort=true, tlsPort=-1, enableTlsPort=false}, nodeType='coordinator', services={}}].
2019-03-21T13:26:34,570 INFO [NodeTypeWatcher[coordinator]] io.druid.curator.discovery.CuratorDruidNodeDiscoveryProvider$NodeTypeWatcher - Received INITIALIZED in node watcher for type [coordinator].
2019-03-21T13:26:34,612 INFO [main] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8081
2019-03-21T13:26:34,614 INFO [main] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8081
2019-03-21T13:26:34,616 INFO [main] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8081
2019-03-21T13:26:34,617 INFO [main] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8081
2019-03-21T13:26:34,618 INFO [main] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8081
2019-03-21T13:26:34,622 INFO [main] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8081
2019-03-21T13:26:34,624 INFO [main] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8081
2019-03-21T13:26:34,626 INFO [main] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8081
2019-03-21T13:26:34,627 INFO [main] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8081
2019-03-21T13:26:34,628 INFO [main] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8081
2019-03-21T13:26:34,629 INFO [main] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8081
2019-03-21T13:26:34,630 INFO [main] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8081
2019-03-21T13:26:34,631 INFO [main] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8081
2019-03-21T13:26:34,632 INFO [main] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8081
2019-03-21T13:26:34,633 INFO [main] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8081
2019-03-21T13:26:34,634 INFO [main] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8081
2019-03-21T13:26:34,635 INFO [main] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8081
2019-03-21T13:26:34,636 INFO [main] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8081
2019-03-21T13:26:34,637 INFO [main] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8081
2019-03-21T13:26:34,683 WARN [main] io.druid.query.lookup.LookupReferencesManager - No lookups found for tier [__default], response [io.druid.java.util.http.client.response.FullResponseHolder@6c075e9d]
2019-03-21T13:26:34,684 INFO [main] io.druid.query.lookup.LookupReferencesManager - Coordinator is unavailable. Loading saved snapshot instead
2019-03-21T13:26:34,684 INFO [main] io.druid.query.lookup.LookupReferencesManager - No lookups to be loaded at this point
2019-03-21T13:26:34,686 INFO [main] io.druid.query.lookup.LookupReferencesManager - LookupReferencesManager is started.
2019-03-21T13:26:34,688 INFO [main] io.druid.java.util.common.lifecycle.Lifecycle$AnnotationBasedHandler - Invoking start method[public void io.druid.java.util.metrics.MonitorScheduler.start()] on object[io.druid.java.util.metrics.MonitorScheduler@4a642e4b].
2019-03-21T13:26:34,691 INFO [main] io.druid.java.util.common.lifecycle.Lifecycle$AnnotationBasedHandler - Invoking start method[public void io.druid.curator.discovery.ServerDiscoverySelector.start() throws java.lang.Exception] on object[io.druid.curator.discovery.ServerDiscoverySelector@5600a5da].
2019-03-21T13:26:34,699 INFO [main] io.druid.java.util.common.lifecycle.Lifecycle$AnnotationBasedHandler - Invoking start method[public void io.druid.discovery.DruidLeaderClient.start()] on object[io.druid.discovery.DruidLeaderClient@4a864d4d].
2019-03-21T13:26:34,699 INFO [main] io.druid.curator.discovery.CuratorDruidNodeDiscoveryProvider - Creating NodeTypeWatcher for nodeType [overlord].
2019-03-21T13:26:34,700 INFO [main] io.druid.curator.discovery.CuratorDruidNodeDiscoveryProvider - Created NodeTypeWatcher for nodeType [overlord].
2019-03-21T13:26:34,700 INFO [main] io.druid.discovery.DruidLeaderClient - Started.
2019-03-21T13:26:34,700 INFO [main] io.druid.java.util.common.lifecycle.Lifecycle$AnnotationBasedHandler - Invoking start method[public void io.druid.curator.announcement.Announcer.start()] on object[io.druid.curator.announcement.Announcer@7558c24b].
2019-03-21T13:26:34,700 INFO [main] io.druid.curator.announcement.Announcer - Starting announcer
2019-03-21T13:26:34,704 INFO [main] io.druid.java.util.common.lifecycle.Lifecycle$AnnotationBasedHandler - Invoking start method[public void io.druid.indexing.worker.executor.ExecutorLifecycle.start() throws java.lang.InterruptedException] on object[io.druid.indexing.worker.executor.ExecutorLifecycle@501957bf].
2019-03-21T13:26:34,717 INFO [NodeTypeWatcher[overlord]] io.druid.curator.discovery.CuratorDruidNodeDiscoveryProvider$NodeTypeWatcher - Received event [CHILD_ADDED] for Node[overlord:DiscoveryDruidNode{druidNode=DruidNode{serviceName='druid/overlord', host='staging-druid-01.ams01.voice-extranet.prv', port=-1, plaintextPort=8090, enablePlaintextPort=true, tlsPort=-1, enableTlsPort=false}, nodeType='overlord', services={}}].
2019-03-21T13:26:34,717 INFO [NodeTypeWatcher[overlord]] io.druid.curator.discovery.CuratorDruidNodeDiscoveryProvider$NodeTypeWatcher - Received INITIALIZED in node watcher for type [overlord].
2019-03-21T13:26:34,769 INFO [main] io.druid.indexing.worker.executor.ExecutorLifecycle - Running with task: {
"type" : "index_kafka",
"id" : "index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea_mgffnnmc",
"resource" : {
"availabilityGroup" : "index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea",
"requiredCapacity" : 1
},
"dataSchema" : {
"dataSource" : "unrated-cdr-slim-rollup-large-new",
"parser" : {
"type" : "string",
"parseSpec" : {
"format" : "json",
"timestampSpec" : {
"format" : "iso",
"column" : "@timestamp"
},
"dimensionsSpec" : {
"dimensions" : [ "incoming_denver_contract_id", "outgoing_denver_contract_id", "incoming_denver_customer_id", "outgoing_denver_customer_id", "incoming_insight_customer_id", "outgoing_insight_customer_id", "incoming_contract_desc", "outgoing_contract_desc", "incoming_customer_name", "outgoing_customer_name", "orig_mkt_id", "dest_mkt_id", "origin_country_name", "dest_country_name", "orig_operator_desc", "dest_operator_desc", {
"type" : "long",
"name" : "is_answered"
} ]
}
}
},
"metricsSpec" : [ {
"type" : "count",
"name" : "total_calls"
}, {
"type" : "longSum",
"name" : "isaner_long",
"fieldName" : "isaner_long",
"expression" : null
}, {
"type" : "floatSum",
"name" : "real_duration_long",
"fieldName" : "real_duration_long",
"expression" : null
}, {
"type" : "longSum",
"name" : "total_calls_ok",
"fieldName" : "total_calls_ok",
"expression" : null
} ],
"granularitySpec" : {
"type" : "uniform",
"segmentGranularity" : "DAY",
"queryGranularity" : {
"type" : "none"
},
"rollup" : true,
"intervals" : null
},
"transformSpec" : {
"filter" : null,
"transforms" : [ {
"type" : "expression",
"name" : "isaner_long",
"expression" : "cast(isaner,'long')"
}, {
"type" : "expression",
"name" : "real_duration_long",
"expression" : "cast(real_duration,'double')"
}, {
"type" : "expression",
"name" : "total_calls_ok",
"expression" : "cast(if(cast(rounded_duration,'LONG') > 0,1,0),'LONG')"
} ]
}
},
"tuningConfig" : {
"type" : "KafkaTuningConfig",
"maxRowsInMemory" : 75000,
"maxRowsPerSegment" : 5000000,
"intermediatePersistPeriod" : "PT10M",
"basePersistDirectory" : "/opt/druid-0.12.3/var/tmp/1553084867805-0",
"maxPendingPersists" : 0,
"indexSpec" : {
"bitmap" : {
"type" : "concise"
},
"dimensionCompression" : "lz4",
"metricCompression" : "lz4",
"longEncoding" : "longs"
},
"buildV9Directly" : true,
"reportParseExceptions" : false,
"handoffConditionTimeout" : 0,
"resetOffsetAutomatically" : false,
"segmentWriteOutMediumFactory" : null
},
"ioConfig" : {
"type" : "kafka",
"taskGroupId" : 0,
"baseSequenceName" : "index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea",
"startPartitions" : {
"topic" : "unrated_cdr",
"partitionOffsetMap" : {
"0" : 0,
"1" : 0,
"2" : 0,
"3" : 0,
"4" : 0,
"5" : 0,
"6" : 0,
"7" : 0,
"8" : 0,
"9" : 0,
"10" : 0,
"11" : 0,
"12" : 0,
"13" : 0,
"14" : 0,
"15" : 0,
"16" : 0,
"17" : 0,
"18" : 0,
"19" : 0,
"20" : 0,
"21" : 0,
"22" : 0,
"23" : 0,
"24" : 0,
"25" : 0,
"26" : 0,
"27" : 0,
"28" : 0,
"29" : 0
}
},
"endPartitions" : {
"topic" : "unrated_cdr",
"partitionOffsetMap" : {
"0" : 9223372036854775807,
"1" : 9223372036854775807,
"2" : 9223372036854775807,
"3" : 9223372036854775807,
"4" : 9223372036854775807,
"5" : 9223372036854775807,
"6" : 9223372036854775807,
"7" : 9223372036854775807,
"8" : 9223372036854775807,
"9" : 9223372036854775807,
"10" : 9223372036854775807,
"11" : 9223372036854775807,
"12" : 9223372036854775807,
"13" : 9223372036854775807,
"14" : 9223372036854775807,
"15" : 9223372036854775807,
"16" : 9223372036854775807,
"17" : 9223372036854775807,
"18" : 9223372036854775807,
"19" : 9223372036854775807,
"20" : 9223372036854775807,
"21" : 9223372036854775807,
"22" : 9223372036854775807,
"23" : 9223372036854775807,
"24" : 9223372036854775807,
"25" : 9223372036854775807,
"26" : 9223372036854775807,
"27" : 9223372036854775807,
"28" : 9223372036854775807,
"29" : 9223372036854775807
}
},
"consumerProperties" : {
"bootstrap.servers" : "staging-druid-01.ams01.voice-extranet.prv:9092"
},
"useTransaction" : true,
"minimumMessageTime" : null,
"maximumMessageTime" : null,
"skipOffsetGaps" : false
},
"context" : {
"checkpoints" : "{\"0\":{\"0\":0,\"1\":0,\"2\":0,\"3\":0,\"4\":0,\"5\":0,\"6\":0,\"7\":0,\"8\":0,\"9\":0,\"10\":0,\"11\":0,\"12\":0,\"13\":0,\"14\":0,\"15\":0,\"16\":0,\"17\":0,\"18\":0,\"19\":0,\"20\":0,\"21\":0,\"22\":0,\"23\":0,\"24\":0,\"25\":0,\"26\":0,\"27\":0,\"28\":0,\"29\":0}}",
"IS_INCREMENTAL_HANDOFF_SUPPORTED" : true
},
"groupId" : "index_kafka_unrated-cdr-slim-rollup-large-new",
"dataSource" : "unrated-cdr-slim-rollup-large-new"
}
2019-03-21T13:26:34,773 INFO [main] io.druid.indexing.worker.executor.ExecutorLifecycle - Attempting to lock file[/data/druid/task/index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea_mgffnnmc/lock].
2019-03-21T13:26:34,778 INFO [main] io.druid.indexing.worker.executor.ExecutorLifecycle - Acquired lock file[/data/druid/task/index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea_mgffnnmc/lock] in 5ms.
2019-03-21T13:26:34,787 INFO [task-runner-0-priority-0] io.druid.indexing.overlord.ThreadPoolTaskRunner - Running task: index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea_mgffnnmc
2019-03-21T13:26:34,789 INFO [task-runner-0-priority-0] io.druid.indexing.overlord.TaskRunnerUtils - Task [index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea_mgffnnmc] location changed to [TaskLocation{host='staging-druid-01.ams01.voice-extranet.prv', port=8100, tlsPort=-1}].
2019-03-21T13:26:34,790 INFO [task-runner-0-priority-0] io.druid.indexing.overlord.TaskRunnerUtils - Task [index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea_mgffnnmc] status changed to [RUNNING].
2019-03-21T13:26:34,791 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Starting up!
2019-03-21T13:26:34,791 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Checkpoints [{"0":{"0":0,"1":0,"2":0,"3":0,"4":0,"5":0,"6":0,"7":0,"8":0,"9":0,"10":0,"11":0,"12":0,"13":0,"14":0,"15":0,"16":0,"17":0,"18":0,"19":0,"20":0,"21":0,"22":0,"23":0,"24":0,"25":0,"26":0,"27":0,"28":0,"29":0}}]
2019-03-21T13:26:34,806 INFO [main] io.druid.server.initialization.jetty.JettyServerModule - Starting Jetty Server...
2019-03-21T13:26:34,810 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Starting with sequences: [SequenceMetadata{sequenceName='index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea_0', sequenceId=0, startOffsets={0=0, 1=0, 2=0, 3=0, 4=0, 5=0, 6=0, 7=0, 8=0, 9=0, 10=0, 11=0, 12=0, 13=0, 14=0, 15=0, 16=0, 17=0, 18=0, 19=0, 20=0, 21=0, 22=0, 23=0, 24=0, 25=0, 26=0, 27=0, 28=0, 29=0}, endOffsets={0=9223372036854775807, 1=9223372036854775807, 2=9223372036854775807, 3=9223372036854775807, 4=9223372036854775807, 5=9223372036854775807, 6=9223372036854775807, 7=9223372036854775807, 8=9223372036854775807, 9=9223372036854775807, 10=9223372036854775807, 11=9223372036854775807, 12=9223372036854775807, 13=9223372036854775807, 14=9223372036854775807, 15=9223372036854775807, 16=9223372036854775807, 17=9223372036854775807, 18=9223372036854775807, 19=9223372036854775807, 20=9223372036854775807, 21=9223372036854775807, 22=9223372036854775807, 23=9223372036854775807, 24=9223372036854775807, 25=9223372036854775807, 26=9223372036854775807, 27=9223372036854775807, 28=9223372036854775807, 29=9223372036854775807}, assignments=[0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21, 22, 23, 24, 25, 26, 27, 28, 29], sentinel=false, checkpointed=false}]
2019-03-21T13:26:34,810 INFO [main] org.eclipse.jetty.server.Server - jetty-9.3.19.v20170502
2019-03-21T13:26:34,810 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Found chat handler of class[io.druid.segment.realtime.firehose.ServiceAnnouncingChatHandlerProvider]
2019-03-21T13:26:34,810 INFO [task-runner-0-priority-0] io.druid.segment.realtime.firehose.ServiceAnnouncingChatHandlerProvider - Registering Eventhandler[index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea_mgffnnmc]
2019-03-21T13:26:34,871 INFO [task-runner-0-priority-0] org.apache.kafka.clients.consumer.ConsumerConfig - ConsumerConfig values:
auto.commit.interval.ms = 5000
auto.offset.reset = none
bootstrap.servers = [staging-druid-01.ams01.voice-extranet.prv:9092]
check.crcs = true
client.id =
connections.max.idle.ms = 540000
enable.auto.commit = false
exclude.internal.topics = true
fetch.max.bytes = 52428800
fetch.max.wait.ms = 500
fetch.min.bytes = 1
group.id =
heartbeat.interval.ms = 3000
interceptor.classes = null
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 = 300000
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.ms = 50
request.timeout.ms = 305000
retry.backoff.ms = 100
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.mechanism = GSSAPI
security.protocol = PLAINTEXT
send.buffer.bytes = 131072
session.timeout.ms = 10000
ssl.cipher.suites = null
ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
ssl.endpoint.identification.algorithm = null
ssl.key.password = null
ssl.keymanager.algorithm = SunX509
ssl.keystore.location = null
ssl.keystore.password = null
ssl.keystore.type = JKS
ssl.protocol = TLS
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
2019-03-21T13:26:34,890 INFO [task-runner-0-priority-0] org.apache.kafka.clients.consumer.ConsumerConfig - ConsumerConfig values:
auto.commit.interval.ms = 5000
auto.offset.reset = none
bootstrap.servers = [staging-druid-01.ams01.voice-extranet.prv:9092]
check.crcs = true
client.id = consumer-1
connections.max.idle.ms = 540000
enable.auto.commit = false
exclude.internal.topics = true
fetch.max.bytes = 52428800
fetch.max.wait.ms = 500
fetch.min.bytes = 1
group.id =
heartbeat.interval.ms = 3000
interceptor.classes = null
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 = 300000
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.ms = 50
request.timeout.ms = 305000
retry.backoff.ms = 100
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.mechanism = GSSAPI
security.protocol = PLAINTEXT
send.buffer.bytes = 131072
session.timeout.ms = 10000
ssl.cipher.suites = null
ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
ssl.endpoint.identification.algorithm = null
ssl.key.password = null
ssl.keymanager.algorithm = SunX509
ssl.keystore.location = null
ssl.keystore.password = null
ssl.keystore.type = JKS
ssl.protocol = TLS
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
2019-03-21T13:26:34,998 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Registering io.druid.server.http.SegmentListerResource as a root resource class
2019-03-21T13:26:35,000 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Registering com.fasterxml.jackson.jaxrs.json.JacksonJsonProvider as a provider class
2019-03-21T13:26:35,001 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Registering com.fasterxml.jackson.jaxrs.smile.JacksonSmileProvider as a provider class
2019-03-21T13:26:35,001 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Registering io.druid.server.initialization.jetty.CustomExceptionMapper as a provider class
2019-03-21T13:26:35,001 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Registering io.druid.server.initialization.jetty.ForbiddenExceptionMapper as a provider class
2019-03-21T13:26:35,001 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Registering io.druid.server.StatusResource as a root resource class
2019-03-21T13:26:35,004 INFO [task-runner-0-priority-0] org.apache.kafka.common.utils.AppInfoParser - Kafka version : 0.10.2.0
2019-03-21T13:26:35,004 INFO [task-runner-0-priority-0] org.apache.kafka.common.utils.AppInfoParser - Kafka commitId : 576d93a8dc0cf421
2019-03-21T13:26:35,005 INFO [main] com.sun.jersey.server.impl.application.WebApplicationImpl - Initiating Jersey application, version 'Jersey: 1.19.3 10/24/2016 03:43 PM'
2019-03-21T13:26:35,005 INFO [task-runner-0-priority-0] io.druid.server.coordination.CuratorDataSegmentServerAnnouncer - Announcing self[DruidServerMetadata{name='staging-druid-01.ams01.voice-extranet.prv:8100', hostAndPort='staging-druid-01.ams01.voice-extranet.prv:8100', hostAndTlsPort='null', maxSize=0, tier='_default_tier', type=indexer-executor, priority=0}] at [/druid/announcements/staging-druid-01.ams01.voice-extranet.prv:8100]
2019-03-21T13:26:35,044 INFO [task-runner-0-priority-0] io.druid.curator.discovery.CuratorDruidNodeAnnouncer - Announcing [DiscoveryDruidNode{druidNode=DruidNode{serviceName='druid/middleManager', host='staging-druid-01.ams01.voice-extranet.prv', port=-1, plaintextPort=8100, enablePlaintextPort=true, tlsPort=-1, enableTlsPort=false}, nodeType='peon', services={dataNodeService=DataNodeService{tier='_default_tier', maxSize=0, type=indexer-executor, priority=0}, lookupNodeService=LookupNodeService{lookupTier='__default'}}}].
2019-03-21T13:26:35,062 INFO [task-runner-0-priority-0] io.druid.curator.discovery.CuratorDruidNodeAnnouncer - Announced [DiscoveryDruidNode{druidNode=DruidNode{serviceName='druid/middleManager', host='staging-druid-01.ams01.voice-extranet.prv', port=-1, plaintextPort=8100, enablePlaintextPort=true, tlsPort=-1, enableTlsPort=false}, nodeType='peon', services={dataNodeService=DataNodeService{tier='_default_tier', maxSize=0, type=indexer-executor, priority=0}, lookupNodeService=LookupNodeService{lookupTier='__default'}}}].
2019-03-21T13:26:35,084 INFO [task-runner-0-priority-0] io.druid.segment.realtime.appenderator.AppenderatorImpl - Created Appenderator for dataSource[unrated-cdr-slim-rollup-large-new].
2019-03-21T13:26:35,094 INFO [task-runner-0-priority-0] io.druid.segment.realtime.appenderator.AppenderatorImpl - Loading sinks from[/data/druid/task/index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea_mgffnnmc/work/persist]: []
2019-03-21T13:26:35,098 INFO [task-runner-0-priority-0] io.druid.segment.realtime.appenderator.StreamAppenderatorDriver - Restored metadata[null].
2019-03-21T13:26:35,116 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Seeking partition[0] to offset[0].
2019-03-21T13:26:35,116 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Seeking partition[1] to offset[0].
2019-03-21T13:26:35,116 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Seeking partition[2] to offset[0].
2019-03-21T13:26:35,117 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Seeking partition[3] to offset[0].
2019-03-21T13:26:35,117 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Seeking partition[4] to offset[0].
2019-03-21T13:26:35,117 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Seeking partition[5] to offset[0].
2019-03-21T13:26:35,117 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Seeking partition[6] to offset[0].
2019-03-21T13:26:35,117 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Seeking partition[7] to offset[0].
2019-03-21T13:26:35,118 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Seeking partition[8] to offset[0].
2019-03-21T13:26:35,118 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Seeking partition[9] to offset[0].
2019-03-21T13:26:35,118 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Seeking partition[10] to offset[0].
2019-03-21T13:26:35,118 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Seeking partition[11] to offset[0].
2019-03-21T13:26:35,118 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Seeking partition[12] to offset[0].
2019-03-21T13:26:35,119 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Seeking partition[13] to offset[0].
2019-03-21T13:26:35,119 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Seeking partition[14] to offset[0].
2019-03-21T13:26:35,119 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Seeking partition[15] to offset[0].
2019-03-21T13:26:35,119 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Seeking partition[16] to offset[0].
2019-03-21T13:26:35,119 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Seeking partition[17] to offset[0].
2019-03-21T13:26:35,120 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Seeking partition[18] to offset[0].
2019-03-21T13:26:35,120 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Seeking partition[19] to offset[0].
2019-03-21T13:26:35,120 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Seeking partition[20] to offset[0].
2019-03-21T13:26:35,120 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Seeking partition[21] to offset[0].
2019-03-21T13:26:35,120 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Seeking partition[22] to offset[0].
2019-03-21T13:26:35,120 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Seeking partition[23] to offset[0].
2019-03-21T13:26:35,121 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Seeking partition[24] to offset[0].
2019-03-21T13:26:35,121 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Seeking partition[25] to offset[0].
2019-03-21T13:26:35,121 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Seeking partition[26] to offset[0].
2019-03-21T13:26:35,121 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Seeking partition[27] to offset[0].
2019-03-21T13:26:35,122 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Seeking partition[28] to offset[0].
2019-03-21T13:26:35,122 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Seeking partition[29] to offset[0].
2019-03-21T13:26:35,155 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Binding io.druid.server.initialization.jetty.CustomExceptionMapper to GuiceManagedComponentProvider with the scope "Singleton"
2019-03-21T13:26:35,159 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Binding io.druid.server.initialization.jetty.ForbiddenExceptionMapper to GuiceManagedComponentProvider with the scope "Singleton"
2019-03-21T13:26:35,160 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Binding com.fasterxml.jackson.jaxrs.json.JacksonJsonProvider to GuiceManagedComponentProvider with the scope "Singleton"
2019-03-21T13:26:35,171 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Binding com.fasterxml.jackson.jaxrs.smile.JacksonSmileProvider to GuiceManagedComponentProvider with the scope "Singleton"
2019-03-21T13:26:35,702 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Binding io.druid.server.http.security.StateResourceFilter to GuiceInstantiatedComponentProvider
2019-03-21T13:26:35,732 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Binding io.druid.server.http.SegmentListerResource to GuiceManagedComponentProvider with the scope "PerRequest"
2019-03-21T13:26:35,741 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Binding io.druid.server.QueryResource to GuiceInstantiatedComponentProvider
2019-03-21T13:26:35,749 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Binding io.druid.segment.realtime.firehose.ChatHandlerResource to GuiceInstantiatedComponentProvider
2019-03-21T13:26:35,752 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Binding io.druid.server.http.security.ConfigResourceFilter to GuiceInstantiatedComponentProvider
2019-03-21T13:26:35,757 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Binding io.druid.query.lookup.LookupListeningResource to GuiceInstantiatedComponentProvider
2019-03-21T13:26:35,759 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Binding io.druid.query.lookup.LookupIntrospectionResource to GuiceInstantiatedComponentProvider
2019-03-21T13:26:35,761 INFO [main] com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory - Binding io.druid.server.StatusResource to GuiceManagedComponentProvider with the scope "Undefined"
2019-03-21T13:26:35,787 WARN [main] com.sun.jersey.spi.inject.Errors - The following warnings have been detected with resource and/or provider classes:
WARNING: A HTTP GET method, public void io.druid.server.http.SegmentListerResource.getSegments(long,long,long,javax.servlet.http.HttpServletRequest) throws java.io.IOException, MUST return a non-void type.
2019-03-21T13:26:35,804 INFO [main] org.eclipse.jetty.server.handler.ContextHandler - Started o.e.j.s.ServletContextHandler@49653791{/,null,AVAILABLE}
2019-03-21T13:26:35,822 INFO [main] org.eclipse.jetty.server.AbstractConnector - Started ServerConnector@6e0d16a4{HTTP/1.1,[http/1.1]}{0.0.0.0:8100}
2019-03-21T13:26:35,822 INFO [main] org.eclipse.jetty.server.Server - Started @10887ms
2019-03-21T13:26:35,823 INFO [main] io.druid.java.util.common.lifecycle.Lifecycle$AnnotationBasedHandler - Invoking start method[public void io.druid.server.listener.announcer.ListenerResourceAnnouncer.start()] on object[io.druid.query.lookup.LookupResourceListenerAnnouncer@25e8e59].
2019-03-21T13:26:35,827 INFO [main] io.druid.server.listener.announcer.ListenerResourceAnnouncer - Announcing start time on [/druid/listeners/lookups/__default/http:staging-druid-01.ams01.voice-extranet.prv:8100]
2019-03-21T13:30:46,599 INFO [task-runner-0-priority-0] io.druid.indexing.common.actions.RemoteTaskActionClient - Performing action for task[index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea_mgffnnmc]: SegmentAllocateAction{dataSource='unrated-cdr-slim-rollup-large-new', timestamp=2019-03-11T01:21:20.000Z, queryGranularity=NoneGranularity, preferredSegmentGranularity={type=period, period=P1D, timeZone=UTC, origin=null}, sequenceName='index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea_0', previousSegmentId='null', skipSegmentLineageCheck='true'}
2019-03-21T13:30:46,618 INFO [task-runner-0-priority-0] io.druid.indexing.common.actions.RemoteTaskActionClient - Submitting action for task[index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea_mgffnnmc] to overlord: [SegmentAllocateAction{dataSource='unrated-cdr-slim-rollup-large-new', timestamp=2019-03-11T01:21:20.000Z, queryGranularity=NoneGranularity, preferredSegmentGranularity={type=period, period=P1D, timeZone=UTC, origin=null}, sequenceName='index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea_0', previousSegmentId='null', skipSegmentLineageCheck='true'}].
2019-03-21T13:30:46,619 INFO [task-runner-0-priority-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8090
2019-03-21T13:30:46,621 INFO [task-runner-0-priority-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8090
2019-03-21T13:30:46,621 INFO [task-runner-0-priority-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8090
2019-03-21T13:30:46,622 INFO [task-runner-0-priority-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8090
2019-03-21T13:30:46,623 INFO [task-runner-0-priority-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8090
2019-03-21T13:30:46,624 INFO [task-runner-0-priority-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8090
2019-03-21T13:30:46,625 INFO [task-runner-0-priority-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8090
2019-03-21T13:30:46,625 INFO [task-runner-0-priority-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8090
2019-03-21T13:30:46,626 INFO [task-runner-0-priority-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8090
2019-03-21T13:30:46,627 INFO [task-runner-0-priority-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8090
2019-03-21T13:30:46,629 INFO [task-runner-0-priority-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8090
2019-03-21T13:30:46,630 INFO [task-runner-0-priority-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8090
2019-03-21T13:30:46,631 INFO [task-runner-0-priority-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8090
2019-03-21T13:30:46,632 INFO [task-runner-0-priority-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8090
2019-03-21T13:30:46,633 INFO [task-runner-0-priority-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8090
2019-03-21T13:30:46,633 INFO [task-runner-0-priority-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8090
2019-03-21T13:30:46,634 INFO [task-runner-0-priority-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8090
2019-03-21T13:30:46,635 INFO [task-runner-0-priority-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8090
2019-03-21T13:30:46,636 INFO [task-runner-0-priority-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8090
2019-03-21T13:30:46,636 INFO [task-runner-0-priority-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8090
2019-03-21T13:30:46,839 INFO [task-runner-0-priority-0] io.druid.segment.realtime.appenderator.BaseAppenderatorDriver - New segment[unrated-cdr-slim-rollup-large-new_2019-03-11T00:00:00.000Z_2019-03-12T00:00:00.000Z_2019-03-21T13:30:46.680Z] for row[io.druid.segment.transform.Transformer$TransformedInputRow@e82fa289] sequenceName[index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea_0].
2019-03-21T13:30:46,943 INFO [task-runner-0-priority-0] io.druid.server.coordination.BatchDataSegmentAnnouncer - Announcing segment[unrated-cdr-slim-rollup-large-new_2019-03-11T00:00:00.000Z_2019-03-12T00:00:00.000Z_2019-03-21T13:30:46.680Z] at new path[/druid/segments/staging-druid-01.ams01.voice-extranet.prv:8100/staging-druid-01.ams01.voice-extranet.prv:8100_indexer-executor__default_tier_2019-03-21T13:30:46.940Z_c62889070daf41a6868066056ca706b10]
2019-03-21T13:36:35,879 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Pausing ingestion until resumed
2019-03-21T13:36:35,913 INFO [qtp1958242673-77] io.druid.indexing.kafka.KafkaIndexTask - Updating endOffsets from [{0=9223372036854775807, 1=9223372036854775807, 2=9223372036854775807, 3=9223372036854775807, 4=9223372036854775807, 5=9223372036854775807, 6=9223372036854775807, 7=9223372036854775807, 8=9223372036854775807, 9=9223372036854775807, 10=9223372036854775807, 11=9223372036854775807, 12=9223372036854775807, 13=9223372036854775807, 14=9223372036854775807, 15=9223372036854775807, 16=9223372036854775807, 17=9223372036854775807, 18=9223372036854775807, 19=9223372036854775807, 20=9223372036854775807, 21=9223372036854775807, 22=9223372036854775807, 23=9223372036854775807, 24=9223372036854775807, 25=9223372036854775807, 26=9223372036854775807, 27=9223372036854775807, 28=9223372036854775807, 29=9223372036854775807}] to [{0=114, 1=118, 2=107, 3=106, 4=117, 5=113, 6=119, 7=129, 8=128, 9=126, 10=138, 11=102, 12=120, 13=130, 14=110, 15=109, 16=122, 17=109, 18=99, 19=99, 20=89, 21=112, 22=121, 23=96, 24=100, 25=100, 26=91, 27=111, 28=94, 29=99}]
2019-03-21T13:36:35,913 INFO [qtp1958242673-77] io.druid.indexing.kafka.KafkaIndexTask - Persisting Sequences Metadata [[SequenceMetadata{sequenceName='index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea_0', sequenceId=0, startOffsets={0=0, 1=0, 2=0, 3=0, 4=0, 5=0, 6=0, 7=0, 8=0, 9=0, 10=0, 11=0, 12=0, 13=0, 14=0, 15=0, 16=0, 17=0, 18=0, 19=0, 20=0, 21=0, 22=0, 23=0, 24=0, 25=0, 26=0, 27=0, 28=0, 29=0}, endOffsets={0=114, 1=118, 2=107, 3=106, 4=117, 5=113, 6=119, 7=129, 8=128, 9=126, 10=138, 11=102, 12=120, 13=130, 14=110, 15=109, 16=122, 17=109, 18=99, 19=99, 20=89, 21=112, 22=121, 23=96, 24=100, 25=100, 26=91, 27=111, 28=94, 29=99}, assignments=[0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21, 22, 23, 24, 25, 26, 27, 28, 29], sentinel=false, checkpointed=true}]]
2019-03-21T13:36:35,918 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Ingestion loop resumed
2019-03-21T13:36:35,918 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Finished reading partition[0].
2019-03-21T13:36:35,918 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Finished reading partition[1].
2019-03-21T13:36:35,918 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Finished reading partition[2].
2019-03-21T13:36:35,918 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Finished reading partition[3].
2019-03-21T13:36:35,918 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Finished reading partition[4].
2019-03-21T13:36:35,918 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Finished reading partition[5].
2019-03-21T13:36:35,918 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Finished reading partition[6].
2019-03-21T13:36:35,918 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Finished reading partition[7].
2019-03-21T13:36:35,919 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Finished reading partition[8].
2019-03-21T13:36:35,919 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Finished reading partition[9].
2019-03-21T13:36:35,919 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Finished reading partition[10].
2019-03-21T13:36:35,919 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Finished reading partition[11].
2019-03-21T13:36:35,919 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Finished reading partition[12].
2019-03-21T13:36:35,919 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Finished reading partition[13].
2019-03-21T13:36:35,919 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Finished reading partition[14].
2019-03-21T13:36:35,919 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Finished reading partition[15].
2019-03-21T13:36:35,919 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Finished reading partition[16].
2019-03-21T13:36:35,919 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Finished reading partition[17].
2019-03-21T13:36:35,919 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Finished reading partition[18].
2019-03-21T13:36:35,920 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Finished reading partition[19].
2019-03-21T13:36:35,920 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Finished reading partition[20].
2019-03-21T13:36:35,920 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Finished reading partition[21].
2019-03-21T13:36:35,920 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Finished reading partition[22].
2019-03-21T13:36:35,920 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Finished reading partition[23].
2019-03-21T13:36:35,920 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Finished reading partition[24].
2019-03-21T13:36:35,920 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Finished reading partition[25].
2019-03-21T13:36:35,920 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Finished reading partition[26].
2019-03-21T13:36:35,921 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Finished reading partition[27].
2019-03-21T13:36:35,921 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Finished reading partition[28].
2019-03-21T13:36:35,921 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Finished reading partition[29].
2019-03-21T13:36:35,929 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - All partitions have been fully read
2019-03-21T13:36:35,929 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Persisting all pending data
2019-03-21T13:36:35,931 INFO [task-runner-0-priority-0] io.druid.segment.realtime.appenderator.StreamAppenderatorDriver - Persisting data.
2019-03-21T13:36:35,941 INFO [task-runner-0-priority-0] io.druid.segment.realtime.appenderator.AppenderatorImpl - Submitting persist runnable for dataSource[unrated-cdr-slim-rollup-large-new]
2019-03-21T13:36:35,947 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.realtime.appenderator.AppenderatorImpl - Segment[unrated-cdr-slim-rollup-large-new_2019-03-11T00:00:00.000Z_2019-03-12T00:00:00.000Z_2019-03-21T13:30:46.680Z], persisting Hydrant[FireHydrant{index=io.druid.segment.incremental.OnheapIncrementalIndex@3a222546, queryable=unrated-cdr-slim-rollup-large-new_2019-03-11T00:00:00.000Z_2019-03-12T00:00:00.000Z_2019-03-21T13:30:46.680Z, count=0}]
2019-03-21T13:36:35,953 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.IndexMergerV9 - Starting persist for interval[2019-03-11T00:00:00.000Z/2019-03-12T00:00:00.000Z], rows[3,061]
2019-03-21T13:36:36,013 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.IndexMergerV9 - Using SegmentWriteOutMediumFactory[TmpFileSegmentWriteOutMediumFactory]
2019-03-21T13:36:36,022 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.IndexMergerV9 - Completed version.bin in 5 millis.
2019-03-21T13:36:36,023 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.IndexMergerV9 - Completed factory.json in 1 millis
2019-03-21T13:36:36,151 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.StringDimensionMergerV9 - Completed dim[incoming_denver_contract_id] conversions with cardinality[40] in 83 millis.
2019-03-21T13:36:36,178 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.StringDimensionMergerV9 - Completed dim[outgoing_denver_contract_id] conversions with cardinality[56] in 5 millis.
2019-03-21T13:36:36,187 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.StringDimensionMergerV9 - Completed dim[incoming_denver_customer_id] conversions with cardinality[38] in 7 millis.
2019-03-21T13:36:36,194 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.StringDimensionMergerV9 - Completed dim[outgoing_denver_customer_id] conversions with cardinality[51] in 6 millis.
2019-03-21T13:36:36,200 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.StringDimensionMergerV9 - Completed dim[incoming_insight_customer_id] conversions with cardinality[37] in 4 millis.
2019-03-21T13:36:36,206 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.StringDimensionMergerV9 - Completed dim[outgoing_insight_customer_id] conversions with cardinality[47] in 4 millis.
2019-03-21T13:36:36,209 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.StringDimensionMergerV9 - Completed dim[incoming_contract_desc] conversions with cardinality[38] in 2 millis.
2019-03-21T13:36:36,214 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.StringDimensionMergerV9 - Completed dim[outgoing_contract_desc] conversions with cardinality[53] in 3 millis.
2019-03-21T13:36:36,219 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.StringDimensionMergerV9 - Completed dim[incoming_customer_name] conversions with cardinality[38] in 4 millis.
2019-03-21T13:36:36,224 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.StringDimensionMergerV9 - Completed dim[outgoing_customer_name] conversions with cardinality[51] in 4 millis.
2019-03-21T13:36:36,233 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.StringDimensionMergerV9 - Completed dim[orig_mkt_id] conversions with cardinality[134] in 8 millis.
2019-03-21T13:36:36,238 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.StringDimensionMergerV9 - Completed dim[dest_mkt_id] conversions with cardinality[64] in 3 millis.
2019-03-21T13:36:36,243 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.StringDimensionMergerV9 - Completed dim[origin_country_name] conversions with cardinality[72] in 4 millis.
2019-03-21T13:36:36,246 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.StringDimensionMergerV9 - Completed dim[dest_country_name] conversions with cardinality[42] in 2 millis.
2019-03-21T13:36:36,249 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.StringDimensionMergerV9 - Completed dim[orig_operator_desc] conversions with cardinality[0] in 0 millis.
2019-03-21T13:36:36,250 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.StringDimensionMergerV9 - Completed dim[dest_operator_desc] conversions with cardinality[0] in 0 millis.
2019-03-21T13:36:36,252 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.IndexMergerV9 - Completed dim conversions in 184 millis.
2019-03-21T13:36:36,389 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.IndexMergerV9 - completed walk through of 3,061 rows in 120 millis.
2019-03-21T13:36:36,413 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.IndexMergerV9 - Completed time column in 24 millis.
2019-03-21T13:36:36,419 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.IndexMergerV9 - Completed metric column[isaner_long] in 6 millis.
2019-03-21T13:36:36,425 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.IndexMergerV9 - Completed metric column[real_duration_long] in 6 millis.
2019-03-21T13:36:36,428 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.IndexMergerV9 - Completed metric column[total_calls] in 3 millis.
2019-03-21T13:36:36,429 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.IndexMergerV9 - Completed metric column[total_calls_ok] in 1 millis.
2019-03-21T13:36:36,429 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.IndexMergerV9 - Completed metric columns in 16 millis.
2019-03-21T13:36:36,459 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.StringDimensionMergerV9 - Completed dim[incoming_denver_contract_id] inverted with cardinality[40] in 30 millis.
2019-03-21T13:36:36,475 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.StringDimensionMergerV9 - Completed dim[outgoing_denver_contract_id] inverted with cardinality[56] in 7 millis.
2019-03-21T13:36:36,490 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.StringDimensionMergerV9 - Completed dim[incoming_denver_customer_id] inverted with cardinality[38] in 13 millis.
2019-03-21T13:36:36,496 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.StringDimensionMergerV9 - Completed dim[outgoing_denver_customer_id] inverted with cardinality[51] in 4 millis.
2019-03-21T13:36:36,501 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.StringDimensionMergerV9 - Completed dim[incoming_insight_customer_id] inverted with cardinality[37] in 3 millis.
2019-03-21T13:36:36,507 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.StringDimensionMergerV9 - Completed dim[outgoing_insight_customer_id] inverted with cardinality[47] in 4 millis.
2019-03-21T13:36:36,512 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.StringDimensionMergerV9 - Completed dim[incoming_contract_desc] inverted with cardinality[38] in 3 millis.
2019-03-21T13:36:36,518 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.StringDimensionMergerV9 - Completed dim[outgoing_contract_desc] inverted with cardinality[53] in 4 millis.
2019-03-21T13:36:36,523 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.StringDimensionMergerV9 - Completed dim[incoming_customer_name] inverted with cardinality[38] in 2 millis.
2019-03-21T13:36:36,529 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.StringDimensionMergerV9 - Completed dim[outgoing_customer_name] inverted with cardinality[51] in 4 millis.
2019-03-21T13:36:36,541 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.StringDimensionMergerV9 - Completed dim[orig_mkt_id] inverted with cardinality[134] in 9 millis.
2019-03-21T13:36:36,549 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.StringDimensionMergerV9 - Completed dim[dest_mkt_id] inverted with cardinality[64] in 4 millis.
2019-03-21T13:36:36,556 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.StringDimensionMergerV9 - Completed dim[origin_country_name] inverted with cardinality[72] in 5 millis.
2019-03-21T13:36:36,560 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.StringDimensionMergerV9 - Completed dim[dest_country_name] inverted with cardinality[42] in 3 millis.
2019-03-21T13:36:36,563 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.StringDimensionMergerV9 - Completed dim[orig_operator_desc] inverted with cardinality[0] in 1 millis.
2019-03-21T13:36:36,564 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.StringDimensionMergerV9 - Completed dim[dest_operator_desc] inverted with cardinality[0] in 1 millis.
2019-03-21T13:36:36,570 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.IndexMergerV9 - Completed index.drd in 5 millis.
2019-03-21T13:36:36,577 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.java.util.common.io.smoosh.FileSmoosher - Created smoosh file [/data/druid/task/index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea_mgffnnmc/work/persist/unrated-cdr-slim-rollup-large-new_2019-03-11T00:00:00.000Z_2019-03-12T00:00:00.000Z_2019-03-21T13:30:46.680Z/0/00000.smoosh] of size [96922] bytes.
2019-03-21T13:36:36,642 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.realtime.appenderator.AppenderatorImpl - Committing metadata[AppenderatorDriverMetadata{segments={index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea_0=[io.druid.segment.realtime.appenderator.SegmentWithState@6c089750]}, lastSegmentIds={index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea_0=unrated-cdr-slim-rollup-large-new_2019-03-11T00:00:00.000Z_2019-03-12T00:00:00.000Z_2019-03-21T13:30:46.680Z}, callerMetadata={nextPartitions=KafkaPartitions{topic='unrated_cdr', partitionOffsetMap={0=114, 1=118, 2=107, 3=106, 4=117, 5=113, 6=119, 7=129, 8=128, 9=126, 10=138, 11=102, 12=120, 13=130, 14=110, 15=109, 16=122, 17=109, 18=99, 19=99, 20=89, 21=112, 22=121, 23=96, 24=100, 25=100, 26=91, 27=111, 28=94, 29=99}}}}] for sinks[unrated-cdr-slim-rollup-large-new_2019-03-11T00:00:00.000Z_2019-03-12T00:00:00.000Z_2019-03-21T13:30:46.680Z:1].
2019-03-21T13:36:36,652 INFO [task-runner-0-priority-0] io.druid.segment.realtime.appenderator.StreamAppenderatorDriver - Persisted pending data in 721ms.
2019-03-21T13:36:36,652 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Publishing segments for sequence [SequenceMetadata{sequenceName='index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea_0', sequenceId=0, startOffsets={0=0, 1=0, 2=0, 3=0, 4=0, 5=0, 6=0, 7=0, 8=0, 9=0, 10=0, 11=0, 12=0, 13=0, 14=0, 15=0, 16=0, 17=0, 18=0, 19=0, 20=0, 21=0, 22=0, 23=0, 24=0, 25=0, 26=0, 27=0, 28=0, 29=0}, endOffsets={0=114, 1=118, 2=107, 3=106, 4=117, 5=113, 6=119, 7=129, 8=128, 9=126, 10=138, 11=102, 12=120, 13=130, 14=110, 15=109, 16=122, 17=109, 18=99, 19=99, 20=89, 21=112, 22=121, 23=96, 24=100, 25=100, 26=91, 27=111, 28=94, 29=99}, assignments=[], sentinel=false, checkpointed=true}]
2019-03-21T13:36:36,666 INFO [task-runner-0-priority-0] io.druid.segment.realtime.appenderator.BaseAppenderatorDriver - Pushing segments in background: [unrated-cdr-slim-rollup-large-new_2019-03-11T00:00:00.000Z_2019-03-12T00:00:00.000Z_2019-03-21T13:30:46.680Z]
2019-03-21T13:36:36,666 INFO [task-runner-0-priority-0] io.druid.segment.realtime.appenderator.AppenderatorImpl - Submitting persist runnable for dataSource[unrated-cdr-slim-rollup-large-new]
2019-03-21T13:36:36,668 INFO [unrated-cdr-slim-rollup-large-new-incremental-persist] io.druid.segment.realtime.appenderator.AppenderatorImpl - Committing metadata[AppenderatorDriverMetadata{segments={index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea_0=[io.druid.segment.realtime.appenderator.SegmentWithState@6c089750]}, lastSegmentIds={index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea_0=unrated-cdr-slim-rollup-large-new_2019-03-11T00:00:00.000Z_2019-03-12T00:00:00.000Z_2019-03-21T13:30:46.680Z}, callerMetadata={nextPartitions=KafkaPartitions{topic='unrated_cdr', partitionOffsetMap={0=114, 1=118, 2=107, 3=106, 4=117, 5=113, 6=119, 7=129, 8=128, 9=126, 10=138, 11=102, 12=120, 13=130, 14=110, 15=109, 16=122, 17=109, 18=99, 19=99, 20=89, 21=112, 22=121, 23=96, 24=100, 25=100, 26=91, 27=111, 28=94, 29=99}}, publishPartitions=KafkaPartitions{topic='unrated_cdr', partitionOffsetMap={0=114, 1=118, 2=107, 3=106, 4=117, 5=113, 6=119, 7=129, 8=128, 9=126, 10=138, 11=102, 12=120, 13=130, 14=110, 15=109, 16=122, 17=109, 18=99, 19=99, 20=89, 21=112, 22=121, 23=96, 24=100, 25=100, 26=91, 27=111, 28=94, 29=99}}}}] for sinks[unrated-cdr-slim-rollup-large-new_2019-03-11T00:00:00.000Z_2019-03-12T00:00:00.000Z_2019-03-21T13:30:46.680Z:1].
2019-03-21T13:36:36,677 INFO [appenderator_merge_0] io.druid.segment.realtime.appenderator.AppenderatorImpl - Pushing merged index for segment[unrated-cdr-slim-rollup-large-new_2019-03-11T00:00:00.000Z_2019-03-12T00:00:00.000Z_2019-03-21T13:30:46.680Z].
2019-03-21T13:36:36,678 INFO [appenderator_merge_0] io.druid.segment.realtime.appenderator.AppenderatorImpl - Adding hydrant[FireHydrant{index=null, queryable=unrated-cdr-slim-rollup-large-new_2019-03-11T00:00:00.000Z_2019-03-12T00:00:00.000Z_2019-03-21T13:30:46.680Z, count=0}]
2019-03-21T13:36:36,694 INFO [appenderator_merge_0] io.druid.segment.QueryableIndexIndexableAdapter - No dictionary on dimension[is_answered]
2019-03-21T13:36:36,695 INFO [appenderator_merge_0] io.druid.segment.IndexMergerV9 - Using SegmentWriteOutMediumFactory[TmpFileSegmentWriteOutMediumFactory]
2019-03-21T13:36:36,695 INFO [appenderator_merge_0] io.druid.segment.IndexMergerV9 - Completed version.bin in 0 millis.
2019-03-21T13:36:36,696 INFO [appenderator_merge_0] io.druid.segment.IndexMergerV9 - Completed factory.json in 1 millis
2019-03-21T13:36:36,702 INFO [appenderator_merge_0] io.druid.segment.StringDimensionMergerV9 - Completed dim[incoming_denver_contract_id] conversions with cardinality[40] in 4 millis.
2019-03-21T13:36:36,706 INFO [appenderator_merge_0] io.druid.segment.StringDimensionMergerV9 - Completed dim[outgoing_denver_contract_id] conversions with cardinality[56] in 3 millis.
2019-03-21T13:36:36,709 INFO [appenderator_merge_0] io.druid.segment.StringDimensionMergerV9 - Completed dim[incoming_denver_customer_id] conversions with cardinality[38] in 1 millis.
2019-03-21T13:36:36,712 INFO [appenderator_merge_0] io.druid.segment.StringDimensionMergerV9 - Completed dim[outgoing_denver_customer_id] conversions with cardinality[51] in 3 millis.
2019-03-21T13:36:36,715 INFO [appenderator_merge_0] io.druid.segment.StringDimensionMergerV9 - Completed dim[incoming_insight_customer_id] conversions with cardinality[37] in 2 millis.
2019-03-21T13:36:36,719 INFO [appenderator_merge_0] io.druid.segment.StringDimensionMergerV9 - Completed dim[outgoing_insight_customer_id] conversions with cardinality[47] in 3 millis.
2019-03-21T13:36:36,722 INFO [appenderator_merge_0] io.druid.segment.StringDimensionMergerV9 - Completed dim[incoming_contract_desc] conversions with cardinality[38] in 2 millis.
2019-03-21T13:36:36,726 INFO [appenderator_merge_0] io.druid.segment.StringDimensionMergerV9 - Completed dim[outgoing_contract_desc] conversions with cardinality[53] in 3 millis.
2019-03-21T13:36:36,728 INFO [appenderator_merge_0] io.druid.segment.StringDimensionMergerV9 - Completed dim[incoming_customer_name] conversions with cardinality[38] in 1 millis.
2019-03-21T13:36:36,732 INFO [appenderator_merge_0] io.druid.segment.StringDimensionMergerV9 - Completed dim[outgoing_customer_name] conversions with cardinality[51] in 3 millis.
2019-03-21T13:36:36,738 INFO [appenderator_merge_0] io.druid.segment.StringDimensionMergerV9 - Completed dim[orig_mkt_id] conversions with cardinality[134] in 6 millis.
2019-03-21T13:36:36,742 INFO [appenderator_merge_0] io.druid.segment.StringDimensionMergerV9 - Completed dim[dest_mkt_id] conversions with cardinality[64] in 3 millis.
2019-03-21T13:36:36,746 INFO [appenderator_merge_0] io.druid.segment.StringDimensionMergerV9 - Completed dim[origin_country_name] conversions with cardinality[72] in 3 millis.
2019-03-21T13:36:36,749 INFO [appenderator_merge_0] io.druid.segment.StringDimensionMergerV9 - Completed dim[dest_country_name] conversions with cardinality[42] in 2 millis.
2019-03-21T13:36:36,750 INFO [appenderator_merge_0] io.druid.segment.IndexMergerV9 - Completed dim conversions in 52 millis.
2019-03-21T13:36:36,768 INFO [appenderator_merge_0] io.druid.segment.CompressedPools - Allocating new littleEndByteBuf[1]
2019-03-21T13:36:36,769 INFO [appenderator_merge_0] io.druid.segment.CompressedPools - Allocating new littleEndByteBuf[2]
2019-03-21T13:36:36,770 INFO [appenderator_merge_0] io.druid.segment.CompressedPools - Allocating new littleEndByteBuf[3]
2019-03-21T13:36:36,770 INFO [appenderator_merge_0] io.druid.segment.CompressedPools - Allocating new littleEndByteBuf[4]
2019-03-21T13:36:36,772 INFO [appenderator_merge_0] io.druid.segment.CompressedPools - Allocating new littleEndByteBuf[5]
2019-03-21T13:36:36,772 INFO [appenderator_merge_0] io.druid.segment.CompressedPools - Allocating new littleEndByteBuf[6]
2019-03-21T13:36:36,773 INFO [appenderator_merge_0] io.druid.segment.CompressedPools - Allocating new littleEndByteBuf[7]
2019-03-21T13:36:36,773 INFO [appenderator_merge_0] io.druid.segment.CompressedPools - Allocating new littleEndByteBuf[8]
2019-03-21T13:36:36,774 INFO [appenderator_merge_0] io.druid.segment.CompressedPools - Allocating new littleEndByteBuf[9]
2019-03-21T13:36:36,774 INFO [appenderator_merge_0] io.druid.segment.CompressedPools - Allocating new littleEndByteBuf[10]
2019-03-21T13:36:36,774 INFO [appenderator_merge_0] io.druid.segment.CompressedPools - Allocating new littleEndByteBuf[11]
2019-03-21T13:36:36,775 INFO [appenderator_merge_0] io.druid.segment.CompressedPools - Allocating new littleEndByteBuf[12]
2019-03-21T13:36:36,775 INFO [appenderator_merge_0] io.druid.segment.CompressedPools - Allocating new littleEndByteBuf[13]
2019-03-21T13:36:36,775 INFO [appenderator_merge_0] io.druid.segment.CompressedPools - Allocating new littleEndByteBuf[14]
2019-03-21T13:36:36,776 INFO [appenderator_merge_0] io.druid.segment.CompressedPools - Allocating new littleEndByteBuf[15]
2019-03-21T13:36:36,777 INFO [appenderator_merge_0] io.druid.segment.CompressedPools - Allocating new littleEndByteBuf[16]
2019-03-21T13:36:36,777 INFO [appenderator_merge_0] io.druid.segment.CompressedPools - Allocating new littleEndByteBuf[17]
2019-03-21T13:36:36,785 INFO [appenderator_merge_0] io.druid.segment.CompressedPools - Allocating new littleEndByteBuf[18]
2019-03-21T13:36:36,786 INFO [appenderator_merge_0] io.druid.segment.CompressedPools - Allocating new littleEndByteBuf[19]
2019-03-21T13:36:36,786 INFO [appenderator_merge_0] io.druid.segment.CompressedPools - Allocating new littleEndByteBuf[20]
2019-03-21T13:36:36,832 INFO [appenderator_merge_0] io.druid.segment.IndexMergerV9 - completed walk through of 3,061 rows in 75 millis.
2019-03-21T13:36:36,835 INFO [appenderator_merge_0] io.druid.segment.IndexMergerV9 - Completed time column in 3 millis.
2019-03-21T13:36:36,840 INFO [appenderator_merge_0] io.druid.segment.IndexMergerV9 - Completed metric column[isaner_long] in 4 millis.
2019-03-21T13:36:36,842 INFO [appenderator_merge_0] io.druid.segment.IndexMergerV9 - Completed metric column[real_duration_long] in 0 millis.
2019-03-21T13:36:36,844 INFO [appenderator_merge_0] io.druid.segment.IndexMergerV9 - Completed metric column[total_calls] in 2 millis.
2019-03-21T13:36:36,844 INFO [appenderator_merge_0] io.druid.segment.IndexMergerV9 - Completed metric column[total_calls_ok] in 0 millis.
2019-03-21T13:36:36,845 INFO [appenderator_merge_0] io.druid.segment.IndexMergerV9 - Completed metric columns in 9 millis.
2019-03-21T13:36:36,857 INFO [appenderator_merge_0] io.druid.segment.StringDimensionMergerV9 - Completed dim[incoming_denver_contract_id] inverted with cardinality[40] in 12 millis.
2019-03-21T13:36:36,864 INFO [appenderator_merge_0] io.druid.segment.StringDimensionMergerV9 - Completed dim[outgoing_denver_contract_id] inverted with cardinality[56] in 4 millis.
2019-03-21T13:36:36,871 INFO [appenderator_merge_0] io.druid.segment.StringDimensionMergerV9 - Completed dim[incoming_denver_customer_id] inverted with cardinality[38] in 5 millis.
2019-03-21T13:36:36,878 INFO [appenderator_merge_0] io.druid.segment.StringDimensionMergerV9 - Completed dim[outgoing_denver_customer_id] inverted with cardinality[51] in 5 millis.
2019-03-21T13:36:36,885 INFO [appenderator_merge_0] io.druid.segment.StringDimensionMergerV9 - Completed dim[incoming_insight_customer_id] inverted with cardinality[37] in 2 millis.
2019-03-21T13:36:36,889 INFO [appenderator_merge_0] io.druid.segment.StringDimensionMergerV9 - Completed dim[outgoing_insight_customer_id] inverted with cardinality[47] in 2 millis.
2019-03-21T13:36:36,894 INFO [appenderator_merge_0] io.druid.segment.StringDimensionMergerV9 - Completed dim[incoming_contract_desc] inverted with cardinality[38] in 2 millis.
2019-03-21T13:36:36,901 INFO [appenderator_merge_0] io.druid.segment.StringDimensionMergerV9 - Completed dim[outgoing_contract_desc] inverted with cardinality[53] in 4 millis.
2019-03-21T13:36:36,904 INFO [appenderator_merge_0] io.druid.segment.StringDimensionMergerV9 - Completed dim[incoming_customer_name] inverted with cardinality[38] in 2 millis.
2019-03-21T13:36:36,909 INFO [appenderator_merge_0] io.druid.segment.StringDimensionMergerV9 - Completed dim[outgoing_customer_name] inverted with cardinality[51] in 2 millis.
2019-03-21T13:36:36,920 INFO [appenderator_merge_0] io.druid.segment.StringDimensionMergerV9 - Completed dim[orig_mkt_id] inverted with cardinality[134] in 9 millis.
2019-03-21T13:36:36,925 INFO [appenderator_merge_0] io.druid.segment.StringDimensionMergerV9 - Completed dim[dest_mkt_id] inverted with cardinality[64] in 3 millis.
2019-03-21T13:36:36,929 INFO [appenderator_merge_0] io.druid.segment.StringDimensionMergerV9 - Completed dim[origin_country_name] inverted with cardinality[72] in 3 millis.
2019-03-21T13:36:36,935 INFO [appenderator_merge_0] io.druid.segment.StringDimensionMergerV9 - Completed dim[dest_country_name] inverted with cardinality[42] in 4 millis.
2019-03-21T13:36:36,938 INFO [appenderator_merge_0] io.druid.segment.IndexMergerV9 - Completed index.drd in 1 millis.
2019-03-21T13:36:36,940 INFO [appenderator_merge_0] io.druid.java.util.common.io.smoosh.FileSmoosher - Created smoosh file [/data/druid/task/index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea_mgffnnmc/work/persist/unrated-cdr-slim-rollup-large-new_2019-03-11T00:00:00.000Z_2019-03-12T00:00:00.000Z_2019-03-21T13:30:46.680Z/merged/00000.smoosh] of size [96922] bytes.
2019-03-21T13:36:36,948 INFO [appenderator_merge_0] io.druid.segment.QueryableIndexIndexableAdapter - No dictionary on dimension[is_answered]
2019-03-21T13:36:36,954 INFO [appenderator_merge_0] io.druid.segment.loading.LocalDataSegmentPusher - Copying segment[unrated-cdr-slim-rollup-large-new_2019-03-11T00:00:00.000Z_2019-03-12T00:00:00.000Z_2019-03-21T13:30:46.680Z] to local filesystem at location[/data/druid/segments/unrated-cdr-slim-rollup-large-new/2019-03-11T00:00:00.000Z_2019-03-12T00:00:00.000Z/2019-03-21T13:30:46.680Z/0/41ecc709-b487-425a-8218-c02b1f3a8ee1]
2019-03-21T13:36:36,954 INFO [appenderator_merge_0] io.druid.segment.loading.LocalDataSegmentPusher - Creating intermediate directory[/data/druid/segments/intermediate_pushes/76deca7c-252d-46fc-befd-bedc9ba2c0cd] for segment[unrated-cdr-slim-rollup-large-new_2019-03-11T00:00:00.000Z_2019-03-12T00:00:00.000Z_2019-03-21T13:30:46.680Z]
2019-03-21T13:36:36,955 INFO [appenderator_merge_0] io.druid.segment.loading.LocalDataSegmentPusher - Compressing files from[/data/druid/task/index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea_mgffnnmc/work/persist/unrated-cdr-slim-rollup-large-new_2019-03-11T00:00:00.000Z_2019-03-12T00:00:00.000Z_2019-03-21T13:30:46.680Z/merged] to [/data/druid/segments/intermediate_pushes/76deca7c-252d-46fc-befd-bedc9ba2c0cd/index.zip]
2019-03-21T13:36:36,960 INFO [appenderator_merge_0] io.druid.java.util.common.CompressionUtils - Adding file[/data/druid/task/index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea_mgffnnmc/work/persist/unrated-cdr-slim-rollup-large-new_2019-03-11T00:00:00.000Z_2019-03-12T00:00:00.000Z_2019-03-21T13:30:46.680Z/merged/version.bin] with size[4]. Total size so far[0]
2019-03-21T13:36:36,961 INFO [appenderator_merge_0] io.druid.java.util.common.CompressionUtils - Adding file[/data/druid/task/index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea_mgffnnmc/work/persist/unrated-cdr-slim-rollup-large-new_2019-03-11T00:00:00.000Z_2019-03-12T00:00:00.000Z_2019-03-21T13:30:46.680Z/merged/00000.smoosh] with size[96,922]. Total size so far[4]
2019-03-21T13:36:36,969 INFO [appenderator_merge_0] io.druid.java.util.common.CompressionUtils - Adding file[/data/druid/task/index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea_mgffnnmc/work/persist/unrated-cdr-slim-rollup-large-new_2019-03-11T00:00:00.000Z_2019-03-12T00:00:00.000Z_2019-03-21T13:30:46.680Z/merged/meta.smoosh] with size[744]. Total size so far[96,926]
2019-03-21T13:36:36,970 INFO [appenderator_merge_0] io.druid.java.util.common.CompressionUtils - Adding file[/data/druid/task/index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea_mgffnnmc/work/persist/unrated-cdr-slim-rollup-large-new_2019-03-11T00:00:00.000Z_2019-03-12T00:00:00.000Z_2019-03-21T13:30:46.680Z/merged/factory.json] with size[29]. Total size so far[97,670]
2019-03-21T13:36:36,986 INFO [appenderator_merge_0] io.druid.segment.loading.LocalDataSegmentPusher - Creating descriptor file at[/data/druid/segments/intermediate_pushes/76deca7c-252d-46fc-befd-bedc9ba2c0cd/descriptor.json]
2019-03-21T13:36:36,994 INFO [appenderator_merge_0] io.druid.segment.realtime.appenderator.AppenderatorImpl - Pushed merged index for segment[unrated-cdr-slim-rollup-large-new_2019-03-11T00:00:00.000Z_2019-03-12T00:00:00.000Z_2019-03-21T13:30:46.680Z], descriptor is: DataSegment{size=97699, shardSpec=NumberedShardSpec{partitionNum=0, partitions=0}, metrics=[total_calls, isaner_long, real_duration_long, total_calls_ok], dimensions=[incoming_denver_contract_id, outgoing_denver_contract_id, incoming_denver_customer_id, outgoing_denver_customer_id, incoming_insight_customer_id, outgoing_insight_customer_id, incoming_contract_desc, outgoing_contract_desc, incoming_customer_name, outgoing_customer_name, orig_mkt_id, dest_mkt_id, origin_country_name, dest_country_name, is_answered], version='2019-03-21T13:30:46.680Z', loadSpec={type=>local, path=>/data/druid/segments/unrated-cdr-slim-rollup-large-new/2019-03-11T00:00:00.000Z_2019-03-12T00:00:00.000Z/2019-03-21T13:30:46.680Z/0/41ecc709-b487-425a-8218-c02b1f3a8ee1/index.zip}, interval=2019-03-11T00:00:00.000Z/2019-03-12T00:00:00.000Z, dataSource='unrated-cdr-slim-rollup-large-new', binaryVersion='9'}
2019-03-21T13:36:37,007 INFO [publish-0] io.druid.segment.realtime.appenderator.BaseAppenderatorDriver - Publishing segments with commitMetadata[AppenderatorDriverMetadata{segments={index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea_0=[io.druid.segment.realtime.appenderator.SegmentWithState@6c089750]}, lastSegmentIds={index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea_0=unrated-cdr-slim-rollup-large-new_2019-03-11T00:00:00.000Z_2019-03-12T00:00:00.000Z_2019-03-21T13:30:46.680Z}, callerMetadata={nextPartitions=KafkaPartitions{topic='unrated_cdr', partitionOffsetMap={0=114, 1=118, 2=107, 3=106, 4=117, 5=113, 6=119, 7=129, 8=128, 9=126, 10=138, 11=102, 12=120, 13=130, 14=110, 15=109, 16=122, 17=109, 18=99, 19=99, 20=89, 21=112, 22=121, 23=96, 24=100, 25=100, 26=91, 27=111, 28=94, 29=99}}, publishPartitions=KafkaPartitions{topic='unrated_cdr', partitionOffsetMap={0=114, 1=118, 2=107, 3=106, 4=117, 5=113, 6=119, 7=129, 8=128, 9=126, 10=138, 11=102, 12=120, 13=130, 14=110, 15=109, 16=122, 17=109, 18=99, 19=99, 20=89, 21=112, 22=121, 23=96, 24=100, 25=100, 26=91, 27=111, 28=94, 29=99}}}}]: [DataSegment{size=97699, shardSpec=NumberedShardSpec{partitionNum=0, partitions=0}, metrics=[total_calls, isaner_long, real_duration_long, total_calls_ok], dimensions=[incoming_denver_contract_id, outgoing_denver_contract_id, incoming_denver_customer_id, outgoing_denver_customer_id, incoming_insight_customer_id, outgoing_insight_customer_id, incoming_contract_desc, outgoing_contract_desc, incoming_customer_name, outgoing_customer_name, orig_mkt_id, dest_mkt_id, origin_country_name, dest_country_name, is_answered], version='2019-03-21T13:30:46.680Z', loadSpec={type=>local, path=>/data/druid/segments/unrated-cdr-slim-rollup-large-new/2019-03-11T00:00:00.000Z_2019-03-12T00:00:00.000Z/2019-03-21T13:30:46.680Z/0/41ecc709-b487-425a-8218-c02b1f3a8ee1/index.zip}, interval=2019-03-11T00:00:00.000Z/2019-03-12T00:00:00.000Z, dataSource='unrated-cdr-slim-rollup-large-new', binaryVersion='9'}]
2019-03-21T13:36:37,010 INFO [publish-0] io.druid.indexing.kafka.KafkaIndexTask - Publishing with isTransaction[true].
2019-03-21T13:36:37,010 INFO [publish-0] io.druid.indexing.common.actions.RemoteTaskActionClient - Performing action for task[index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea_mgffnnmc]: SegmentInsertAction{segments=[DataSegment{size=97699, shardSpec=NumberedShardSpec{partitionNum=0, partitions=0}, metrics=[total_calls, isaner_long, real_duration_long, total_calls_ok], dimensions=[incoming_denver_contract_id, outgoing_denver_contract_id, incoming_denver_customer_id, outgoing_denver_customer_id, incoming_insight_customer_id, outgoing_insight_customer_id, incoming_contract_desc, outgoing_contract_desc, incoming_customer_name, outgoing_customer_name, orig_mkt_id, dest_mkt_id, origin_country_name, dest_country_name, is_answered], version='2019-03-21T13:30:46.680Z', loadSpec={type=>local, path=>/data/druid/segments/unrated-cdr-slim-rollup-large-new/2019-03-11T00:00:00.000Z_2019-03-12T00:00:00.000Z/2019-03-21T13:30:46.680Z/0/41ecc709-b487-425a-8218-c02b1f3a8ee1/index.zip}, interval=2019-03-11T00:00:00.000Z/2019-03-12T00:00:00.000Z, dataSource='unrated-cdr-slim-rollup-large-new', binaryVersion='9'}], startMetadata=KafkaDataSourceMetadata{kafkaPartitions=KafkaPartitions{topic='unrated_cdr', partitionOffsetMap={0=0, 1=0, 2=0, 3=0, 4=0, 5=0, 6=0, 7=0, 8=0, 9=0, 10=0, 11=0, 12=0, 13=0, 14=0, 15=0, 16=0, 17=0, 18=0, 19=0, 20=0, 21=0, 22=0, 23=0, 24=0, 25=0, 26=0, 27=0, 28=0, 29=0}}}, endMetadata=KafkaDataSourceMetadata{kafkaPartitions=KafkaPartitions{topic='unrated_cdr', partitionOffsetMap={0=114, 1=118, 2=107, 3=106, 4=117, 5=113, 6=119, 7=129, 8=128, 9=126, 10=138, 11=102, 12=120, 13=130, 14=110, 15=109, 16=122, 17=109, 18=99, 19=99, 20=89, 21=112, 22=121, 23=96, 24=100, 25=100, 26=91, 27=111, 28=94, 29=99}}}}
2019-03-21T13:36:37,025 INFO [publish-0] io.druid.indexing.common.actions.RemoteTaskActionClient - Submitting action for task[index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea_mgffnnmc] to overlord: [SegmentInsertAction{segments=[DataSegment{size=97699, shardSpec=NumberedShardSpec{partitionNum=0, partitions=0}, metrics=[total_calls, isaner_long, real_duration_long, total_calls_ok], dimensions=[incoming_denver_contract_id, outgoing_denver_contract_id, incoming_denver_customer_id, outgoing_denver_customer_id, incoming_insight_customer_id, outgoing_insight_customer_id, incoming_contract_desc, outgoing_contract_desc, incoming_customer_name, outgoing_customer_name, orig_mkt_id, dest_mkt_id, origin_country_name, dest_country_name, is_answered], version='2019-03-21T13:30:46.680Z', loadSpec={type=>local, path=>/data/druid/segments/unrated-cdr-slim-rollup-large-new/2019-03-11T00:00:00.000Z_2019-03-12T00:00:00.000Z/2019-03-21T13:30:46.680Z/0/41ecc709-b487-425a-8218-c02b1f3a8ee1/index.zip}, interval=2019-03-11T00:00:00.000Z/2019-03-12T00:00:00.000Z, dataSource='unrated-cdr-slim-rollup-large-new', binaryVersion='9'}], startMetadata=KafkaDataSourceMetadata{kafkaPartitions=KafkaPartitions{topic='unrated_cdr', partitionOffsetMap={0=0, 1=0, 2=0, 3=0, 4=0, 5=0, 6=0, 7=0, 8=0, 9=0, 10=0, 11=0, 12=0, 13=0, 14=0, 15=0, 16=0, 17=0, 18=0, 19=0, 20=0, 21=0, 22=0, 23=0, 24=0, 25=0, 26=0, 27=0, 28=0, 29=0}}}, endMetadata=KafkaDataSourceMetadata{kafkaPartitions=KafkaPartitions{topic='unrated_cdr', partitionOffsetMap={0=114, 1=118, 2=107, 3=106, 4=117, 5=113, 6=119, 7=129, 8=128, 9=126, 10=138, 11=102, 12=120, 13=130, 14=110, 15=109, 16=122, 17=109, 18=99, 19=99, 20=89, 21=112, 22=121, 23=96, 24=100, 25=100, 26=91, 27=111, 28=94, 29=99}}}}].
2019-03-21T13:36:37,026 INFO [publish-0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8090
2019-03-21T13:36:37,143 INFO [publish-0] io.druid.segment.realtime.appenderator.BaseAppenderatorDriver - Published segments.
2019-03-21T13:36:37,147 INFO [publish-0] io.druid.indexing.kafka.KafkaIndexTask - Published segments[[unrated-cdr-slim-rollup-large-new_2019-03-11T00:00:00.000Z_2019-03-12T00:00:00.000Z_2019-03-21T13:30:46.680Z]] with metadata[AppenderatorDriverMetadata{segments={index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea_0=[io.druid.segment.realtime.appenderator.SegmentWithState@6c089750]}, lastSegmentIds={index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea_0=unrated-cdr-slim-rollup-large-new_2019-03-11T00:00:00.000Z_2019-03-12T00:00:00.000Z_2019-03-21T13:30:46.680Z}, callerMetadata={nextPartitions=KafkaPartitions{topic='unrated_cdr', partitionOffsetMap={0=114, 1=118, 2=107, 3=106, 4=117, 5=113, 6=119, 7=129, 8=128, 9=126, 10=138, 11=102, 12=120, 13=130, 14=110, 15=109, 16=122, 17=109, 18=99, 19=99, 20=89, 21=112, 22=121, 23=96, 24=100, 25=100, 26=91, 27=111, 28=94, 29=99}}, publishPartitions=KafkaPartitions{topic='unrated_cdr', partitionOffsetMap={0=114, 1=118, 2=107, 3=106, 4=117, 5=113, 6=119, 7=129, 8=128, 9=126, 10=138, 11=102, 12=120, 13=130, 14=110, 15=109, 16=122, 17=109, 18=99, 19=99, 20=89, 21=112, 22=121, 23=96, 24=100, 25=100, 26=91, 27=111, 28=94, 29=99}}}}].
2019-03-21T13:36:37,148 INFO [publish-0] io.druid.indexing.kafka.KafkaIndexTask - Persisting Sequences Metadata [[]]
2019-03-21T13:36:37,149 INFO [publish-0] io.druid.segment.realtime.appenderator.StreamAppenderatorDriver - Register handoff of segments: [[unrated-cdr-slim-rollup-large-new_2019-03-11T00:00:00.000Z_2019-03-12T00:00:00.000Z_2019-03-21T13:30:46.680Z]]
2019-03-21T13:36:37,151 INFO [publish-0] io.druid.segment.realtime.plumber.CoordinatorBasedSegmentHandoffNotifier - Adding SegmentHandoffCallback for dataSource[unrated-cdr-slim-rollup-large-new] Segment[SegmentDescriptor{interval=2019-03-11T00:00:00.000Z/2019-03-12T00:00:00.000Z, version='2019-03-21T13:30:46.680Z', partitionNumber=0}]
2019-03-21T13:37:35,093 INFO [coordinator_handoff_scheduled_0] io.druid.java.util.http.client.pool.ChannelResourceFactory - Generating: http://staging-druid-01.ams01.voice-extranet.prv:8081
2019-03-21T13:37:35,121 INFO [coordinator_handoff_scheduled_0] io.druid.segment.realtime.plumber.CoordinatorBasedSegmentHandoffNotifier - Segment Handoff complete for dataSource[unrated-cdr-slim-rollup-large-new] Segment[SegmentDescriptor{interval=2019-03-11T00:00:00.000Z/2019-03-12T00:00:00.000Z, version='2019-03-21T13:30:46.680Z', partitionNumber=0}]
2019-03-21T13:37:35,121 INFO [coordinator_handoff_scheduled_0] io.druid.segment.realtime.appenderator.StreamAppenderatorDriver - Segment[unrated-cdr-slim-rollup-large-new_2019-03-11T00:00:00.000Z_2019-03-12T00:00:00.000Z_2019-03-21T13:30:46.680Z] successfully handed off, dropping.
2019-03-21T13:37:35,124 INFO [appenderator_persist_0] io.druid.segment.realtime.appenderator.AppenderatorImpl - Removing commit metadata for segment[unrated-cdr-slim-rollup-large-new_2019-03-11T00:00:00.000Z_2019-03-12T00:00:00.000Z_2019-03-21T13:30:46.680Z].
2019-03-21T13:37:35,129 INFO [appenderator_persist_0] io.druid.server.coordination.BatchDataSegmentAnnouncer - Unannouncing segment[unrated-cdr-slim-rollup-large-new_2019-03-11T00:00:00.000Z_2019-03-12T00:00:00.000Z_2019-03-21T13:30:46.680Z] at path[/druid/segments/staging-druid-01.ams01.voice-extranet.prv:8100/staging-druid-01.ams01.voice-extranet.prv:8100_indexer-executor__default_tier_2019-03-21T13:30:46.940Z_c62889070daf41a6868066056ca706b10]
2019-03-21T13:37:35,129 INFO [appenderator_persist_0] io.druid.curator.announcement.Announcer - unannouncing [/druid/segments/staging-druid-01.ams01.voice-extranet.prv:8100/staging-druid-01.ams01.voice-extranet.prv:8100_indexer-executor__default_tier_2019-03-21T13:30:46.940Z_c62889070daf41a6868066056ca706b10]
2019-03-21T13:37:35,147 INFO [appenderator_persist_0] io.druid.segment.realtime.appenderator.AppenderatorImpl - Removing sink for segment[unrated-cdr-slim-rollup-large-new_2019-03-11T00:00:00.000Z_2019-03-12T00:00:00.000Z_2019-03-21T13:30:46.680Z].
2019-03-21T13:37:35,150 INFO [appenderator_persist_0] io.druid.segment.realtime.appenderator.AppenderatorImpl - Deleting Index File[/data/druid/task/index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea_mgffnnmc/work/persist/unrated-cdr-slim-rollup-large-new_2019-03-11T00:00:00.000Z_2019-03-12T00:00:00.000Z_2019-03-21T13:30:46.680Z]
2019-03-21T13:37:35,151 INFO [appenderator_persist_0] io.druid.segment.realtime.appenderator.StreamAppenderatorDriver - Successfully handed off [1] segments.
2019-03-21T13:37:35,153 INFO [task-runner-0-priority-0] io.druid.indexing.kafka.KafkaIndexTask - Handoff completed for segments[unrated-cdr-slim-rollup-large-new_2019-03-11T00:00:00.000Z_2019-03-12T00:00:00.000Z_2019-03-21T13:30:46.680Z] with metadata[{nextPartitions=KafkaPartitions{topic='unrated_cdr', partitionOffsetMap={0=114, 1=118, 2=107, 3=106, 4=117, 5=113, 6=119, 7=129, 8=128, 9=126, 10=138, 11=102, 12=120, 13=130, 14=110, 15=109, 16=122, 17=109, 18=99, 19=99, 20=89, 21=112, 22=121, 23=96, 24=100, 25=100, 26=91, 27=111, 28=94, 29=99}}, publishPartitions=KafkaPartitions{topic='unrated_cdr', partitionOffsetMap={0=114, 1=118, 2=107, 3=106, 4=117, 5=113, 6=119, 7=129, 8=128, 9=126, 10=138, 11=102, 12=120, 13=130, 14=110, 15=109, 16=122, 17=109, 18=99, 19=99, 20=89, 21=112, 22=121, 23=96, 24=100, 25=100, 26=91, 27=111, 28=94, 29=99}}}].
2019-03-21T13:37:35,153 INFO [task-runner-0-priority-0] io.druid.segment.realtime.appenderator.AppenderatorImpl - Shutting down...
2019-03-21T13:37:35,158 INFO [task-runner-0-priority-0] io.druid.segment.realtime.firehose.ServiceAnnouncingChatHandlerProvider - Unregistering chat handler[index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea_mgffnnmc]
2019-03-21T13:37:35,159 INFO [task-runner-0-priority-0] io.druid.curator.discovery.CuratorDruidNodeAnnouncer - Unannouncing [DiscoveryDruidNode{druidNode=DruidNode{serviceName='druid/middleManager', host='staging-druid-01.ams01.voice-extranet.prv', port=-1, plaintextPort=8100, enablePlaintextPort=true, tlsPort=-1, enableTlsPort=false}, nodeType='peon', services={dataNodeService=DataNodeService{tier='_default_tier', maxSize=0, type=indexer-executor, priority=0}, lookupNodeService=LookupNodeService{lookupTier='__default'}}}].
2019-03-21T13:37:35,159 INFO [task-runner-0-priority-0] io.druid.curator.announcement.Announcer - unannouncing [/druid/internal-discovery/peon/staging-druid-01.ams01.voice-extranet.prv:8100]
2019-03-21T13:37:35,160 INFO [task-runner-0-priority-0] io.druid.curator.discovery.CuratorDruidNodeAnnouncer - Unannounced [DiscoveryDruidNode{druidNode=DruidNode{serviceName='druid/middleManager', host='staging-druid-01.ams01.voice-extranet.prv', port=-1, plaintextPort=8100, enablePlaintextPort=true, tlsPort=-1, enableTlsPort=false}, nodeType='peon', services={dataNodeService=DataNodeService{tier='_default_tier', maxSize=0, type=indexer-executor, priority=0}, lookupNodeService=LookupNodeService{lookupTier='__default'}}}].
2019-03-21T13:37:35,161 INFO [task-runner-0-priority-0] io.druid.server.coordination.CuratorDataSegmentServerAnnouncer - Unannouncing self[DruidServerMetadata{name='staging-druid-01.ams01.voice-extranet.prv:8100', hostAndPort='staging-druid-01.ams01.voice-extranet.prv:8100', hostAndTlsPort='null', maxSize=0, tier='_default_tier', type=indexer-executor, priority=0}] at [/druid/announcements/staging-druid-01.ams01.voice-extranet.prv:8100]
2019-03-21T13:37:35,161 INFO [task-runner-0-priority-0] io.druid.curator.announcement.Announcer - unannouncing [/druid/announcements/staging-druid-01.ams01.voice-extranet.prv:8100]
2019-03-21T13:37:35,164 INFO [task-runner-0-priority-0] io.druid.indexing.overlord.TaskRunnerUtils - Task [index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea_mgffnnmc] status changed to [SUCCESS].
2019-03-21T13:37:35,167 INFO [task-runner-0-priority-0] io.druid.indexing.worker.executor.ExecutorLifecycle - Task completed with status: {
"id" : "index_kafka_unrated-cdr-slim-rollup-large-new_a19243e5200a1ea_mgffnnmc",
"status" : "SUCCESS",
"duration" : 660377
}
2019-03-21T13:37:35,176 INFO [main] io.druid.java.util.common.lifecycle.Lifecycle$AnnotationBasedHandler - Invoking stop method[public void io.druid.server.listener.announcer.ListenerResourceAnnouncer.stop()] on object[io.druid.query.lookup.LookupResourceListenerAnnouncer@25e8e59].
2019-03-21T13:37:35,177 INFO [main] io.druid.curator.announcement.Announcer - unannouncing [/druid/listeners/lookups/__default/http:staging-druid-01.ams01.voice-extranet.prv:8100]
2019-03-21T13:37:35,179 INFO [main] io.druid.server.listener.announcer.ListenerResourceAnnouncer - Unannouncing start time on [/druid/listeners/lookups/__default/http:staging-druid-01.ams01.voice-extranet.prv:8100]
2019-03-21T13:37:35,179 INFO [main] io.druid.server.initialization.jetty.JettyServerModule - Stopping Jetty Server...
2019-03-21T13:37:35,186 INFO [main] org.eclipse.jetty.server.AbstractConnector - Stopped ServerConnector@6e0d16a4{HTTP/1.1,[http/1.1]}{0.0.0.0:8100}
2019-03-21T13:37:35,188 INFO [main] org.eclipse.jetty.server.handler.ContextHandler - Stopped o.e.j.s.ServletContextHandler@49653791{/,null,UNAVAILABLE}
2019-03-21T13:37:35,190 INFO [main] io.druid.java.util.common.lifecycle.Lifecycle$AnnotationBasedHandler - Invoking stop method[public void io.druid.indexing.worker.executor.ExecutorLifecycle.stop() throws java.lang.Exception] on object[io.druid.indexing.worker.executor.ExecutorLifecycle@501957bf].
2019-03-21T13:37:35,191 INFO [main] io.druid.java.util.common.lifecycle.Lifecycle$AnnotationBasedHandler - Invoking stop method[public void io.druid.indexing.overlord.ThreadPoolTaskRunner.stop()] on object[io.druid.indexing.overlord.ThreadPoolTaskRunner@6775c0d1].
2019-03-21T13:37:35,192 INFO [main] io.druid.java.util.common.lifecycle.Lifecycle$AnnotationBasedHandler - Invoking stop method[public void io.druid.curator.announcement.Announcer.stop()] on object[io.druid.curator.announcement.Announcer@7558c24b].
2019-03-21T13:37:35,192 INFO [main] io.druid.curator.announcement.Announcer - Stopping announcer
2019-03-21T13:37:35,192 INFO [main] io.druid.java.util.common.lifecycle.Lifecycle$AnnotationBasedHandler - Invoking stop method[public void io.druid.discovery.DruidLeaderClient.stop()] on object[io.druid.discovery.DruidLeaderClient@4a864d4d].
2019-03-21T13:37:35,192 INFO [main] io.druid.discovery.DruidLeaderClient - Stopped.
2019-03-21T13:37:35,192 INFO [main] 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@5600a5da].
2019-03-21T13:37:35,195 INFO [main] 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@4a642e4b].
2019-03-21T13:37:35,195 INFO [main] io.druid.java.util.common.lifecycle.Lifecycle$AnnotationBasedHandler - Invoking stop method[public void io.druid.query.lookup.LookupReferencesManager.stop()] on object[io.druid.query.lookup.LookupReferencesManager@149274cb].
2019-03-21T13:37:35,195 INFO [main] io.druid.query.lookup.LookupReferencesManager - LookupReferencesManager is stopping.
2019-03-21T13:37:35,195 INFO [LookupReferencesManager-MainThread] io.druid.query.lookup.LookupReferencesManager - Lookup Management loop exited, Lookup notices are not handled anymore.
2019-03-21T13:37:35,195 INFO [main] io.druid.query.lookup.LookupReferencesManager - LookupReferencesManager is stopped.
2019-03-21T13:37:35,196 INFO [main] io.druid.java.util.common.lifecycle.Lifecycle$AnnotationBasedHandler - Invoking stop method[public void io.druid.discovery.DruidLeaderClient.stop()] on object[io.druid.discovery.DruidLeaderClient@7fe8c7db].
2019-03-21T13:37:35,196 INFO [main] io.druid.discovery.DruidLeaderClient - Stopped.
2019-03-21T13:37:35,196 INFO [main] 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@608cd501].
2019-03-21T13:37:35,196 INFO [main] 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@38fb50f8].
2019-03-21T13:37:35,196 INFO [main] io.druid.curator.discovery.CuratorDruidNodeDiscoveryProvider - stopping
2019-03-21T13:37:35,196 INFO [main] io.druid.curator.discovery.CuratorDruidNodeDiscoveryProvider - stopped
2019-03-21T13:37:35,196 INFO [main] 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@6cbb175].
2019-03-21T13:37:35,230 INFO [main] 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=staging-druid-01.ams01.voice-extranet.prv:8100, version=0.12.3}, emitter=io.druid.emitter.statsd.StatsDEmitter@2a685eba}].
2019-03-21T13:37:35,230 INFO [main] 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@57e5396b].
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment