Druid error on all tasks except one org.apache.druid.segment.realtime.appenderator.BaseAppenderatorDriver.getAppendableSegment(BaseAppenderatorDriver.java:294)
367 views
Skip to first unread message
Dejan Zegarac
Oct 5, 2023, 5:37:34 AM10/5/23
to Druid User
Every time I create new kafka ingestion task, I get the following error. The Task stops, and it always tries to create a new one, without much success, getting the same error over and over, and reporting UNHEALTHY TASKS or supervisor errors. I would very much appreciate if someone could give me at a clue to the problem and what to check next.
WARNING: An illegal reflective access operation has occurred
WARNING: Illegal reflective access by com.google.inject.internal.cglib.core.$ReflectUtils$1 (file:/data/apache-druid-26.0.0/lib/guice-4.1.0.jar) to method java.lang.ClassLoader.defineClass(java.lang.String,byte[],int,int,java.security.ProtectionDomain)
WARNING: Please consider reporting this to the maintainers of com.google.inject.internal.cglib.core.$ReflectUtils$1
WARNING: Use --illegal-access=warn to enable warnings of further illegal reflective access operations
WARNING: All illegal access operations will be denied in a future release
2023-10-05T09:29:35,615 INFO [main] org.hibernate.validator.internal.util.Version - HV000001: Hibernate Validator 5.2.5.Final
2023-10-05T09:29:36,455 INFO [main] org.apache.druid.guice.ExtensionsLoader - Loading extension [druid-hdfs-storage], jars: hadoop-mapreduce-client-app-2.8.5.jar, leveldbjni-all-1.8.jar, commons-net-3.6.jar, hadoop-mapreduce-client-shuffle-2.8.5.jar, druid-hdfs-storage-26.0.0.jar, ion-java-1.0.2.jar, hadoop-yarn-server-common-2.8.5.jar, aws-java-sdk-s3-1.12.317.jar, nimbus-jose-jwt-4.41.1.jar, api-util-1.0.3.jar, apacheds-kerberos-codec-2.0.0-M15.jar, commons-digester-1.8.jar, curator-framework-5.4.0.jar, htrace-core4-4.0.1-incubating.jar, hadoop-common-2.8.5.jar, api-asn1-api-1.0.0-M20.jar, hadoop-yarn-client-2.8.5.jar, hadoop-annotations-2.8.5.jar, hadoop-mapreduce-client-core-2.8.5.jar, jcip-annotations-1.0-1.jar, commons-logging-1.1.1.jar, jackson-core-asl-1.9.13.jar, httpcore-4.4.11.jar, jsp-api-2.1.jar, curator-recipes-5.4.0.jar, httpclient-4.5.13.jar, apacheds-i18n-2.0.0-M15.jar, accessors-smart-1.2.jar, hadoop-aws-2.8.5.jar, aws-java-sdk-kms-1.12.317.jar, jmespath-java-1.12.317.jar, commons-codec-1.13.jar, hadoop-mapreduce-client-common-2.8.5.jar, hadoop-auth-2.8.5.jar, joda-time-2.12.4.jar, hadoop-hdfs-client-2.8.5.jar, jetty-sslengine-6.1.26.jar, hadoop-client-2.8.5.jar, hadoop-mapreduce-client-jobclient-2.8.5.jar, hadoop-yarn-api-2.8.5.jar, commons-configuration-1.6.jar, commons-collections-3.2.2.jar, json-smart-2.3.jar, xmlenc-0.52.jar, asm-9.3.jar, jackson-mapper-asl-1.9.13.jar, gson-2.2.4.jar, jackson-dataformat-cbor-2.10.5.jar, aws-java-sdk-core-1.12.317.jar
2023-10-05T09:29:36,485 INFO [main] org.apache.druid.guice.ExtensionsLoader - Loading extension [druid-kafka-indexing-service], jars: lz4-java-1.8.0.jar, snappy-java-1.1.8.4.jar, kafka-clients-3.4.0.jar, druid-kafka-indexing-service-26.0.0.jar, zstd-jni-1.5.2-3.jar
2023-10-05T09:29:36,489 INFO [main] org.apache.druid.guice.ExtensionsLoader - Loading extension [druid-datasketches], jars: commons-math3-3.6.1.jar, druid-datasketches-26.0.0.jar
2023-10-05T09:29:36,491 INFO [main] org.apache.druid.guice.ExtensionsLoader - Loading extension [druid-multi-stage-query], jars: druid-multi-stage-query-26.0.0.jar
2023-10-05T09:29:36,493 INFO [main] org.apache.druid.guice.ExtensionsLoader - Loading extension [mysql-metadata-storage], jars: mysql-metadata-storage-26.0.0.jar, mariadb-java-client-2.7.9.jar
2023-10-05T09:29:36,821 INFO [main] org.apache.druid.guice.ExtensionsLoader - Loading extension [druid-hdfs-storage], jars: hadoop-mapreduce-client-app-2.8.5.jar, leveldbjni-all-1.8.jar, commons-net-3.6.jar, hadoop-mapreduce-client-shuffle-2.8.5.jar, druid-hdfs-storage-26.0.0.jar, ion-java-1.0.2.jar, hadoop-yarn-server-common-2.8.5.jar, aws-java-sdk-s3-1.12.317.jar, nimbus-jose-jwt-4.41.1.jar, api-util-1.0.3.jar, apacheds-kerberos-codec-2.0.0-M15.jar, commons-digester-1.8.jar, curator-framework-5.4.0.jar, htrace-core4-4.0.1-incubating.jar, hadoop-common-2.8.5.jar, api-asn1-api-1.0.0-M20.jar, hadoop-yarn-client-2.8.5.jar, hadoop-annotations-2.8.5.jar, hadoop-mapreduce-client-core-2.8.5.jar, jcip-annotations-1.0-1.jar, commons-logging-1.1.1.jar, jackson-core-asl-1.9.13.jar, httpcore-4.4.11.jar, jsp-api-2.1.jar, curator-recipes-5.4.0.jar, httpclient-4.5.13.jar, apacheds-i18n-2.0.0-M15.jar, accessors-smart-1.2.jar, hadoop-aws-2.8.5.jar, aws-java-sdk-kms-1.12.317.jar, jmespath-java-1.12.317.jar, commons-codec-1.13.jar, hadoop-mapreduce-client-common-2.8.5.jar, hadoop-auth-2.8.5.jar, joda-time-2.12.4.jar, hadoop-hdfs-client-2.8.5.jar, jetty-sslengine-6.1.26.jar, hadoop-client-2.8.5.jar, hadoop-mapreduce-client-jobclient-2.8.5.jar, hadoop-yarn-api-2.8.5.jar, commons-configuration-1.6.jar, commons-collections-3.2.2.jar, json-smart-2.3.jar, xmlenc-0.52.jar, asm-9.3.jar, jackson-mapper-asl-1.9.13.jar, gson-2.2.4.jar, jackson-dataformat-cbor-2.10.5.jar, aws-java-sdk-core-1.12.317.jar
2023-10-05T09:29:36,824 INFO [main] org.apache.druid.guice.ExtensionsLoader - Loading extension [druid-kafka-indexing-service], jars: lz4-java-1.8.0.jar, snappy-java-1.1.8.4.jar, kafka-clients-3.4.0.jar, druid-kafka-indexing-service-26.0.0.jar, zstd-jni-1.5.2-3.jar
2023-10-05T09:29:36,827 INFO [main] org.apache.druid.guice.ExtensionsLoader - Loading extension [druid-datasketches], jars: commons-math3-3.6.1.jar, druid-datasketches-26.0.0.jar
2023-10-05T09:29:36,837 INFO [main] org.apache.druid.guice.ExtensionsLoader - Loading extension [druid-multi-stage-query], jars: druid-multi-stage-query-26.0.0.jar
2023-10-05T09:29:36,854 INFO [main] org.apache.druid.guice.ExtensionsLoader - Loading extension [mysql-metadata-storage], jars: mysql-metadata-storage-26.0.0.jar, mariadb-java-client-2.7.9.jar
2023-10-05T09:29:38,177 WARN [main] org.apache.hadoop.util.NativeCodeLoader - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2023-10-05T09:29:39,704 INFO [main] org.apache.druid.guice.JsonConfigurator - Skipping druid.emitter.logging.logLevel property: one of it's prefixes is also used as a property key. Prefix: druid
2023-10-05T09:29:39,845 INFO [main] org.apache.druid.server.emitter.EmitterModule - Using emitter [NoopEmitter{}] for metrics and alerts, with dimensions [{version=26.0.0}].
2023-10-05T09:29:40,507 INFO [main] org.apache.druid.server.metrics.MetricsModule - Loaded 3 monitors: org.apache.druid.java.util.metrics.JvmMonitor, org.apache.druid.query.ExecutorServiceMonitor, org.apache.druid.server.initialization.jetty.JettyServerModule$JettyMonitor
2023-10-05T09:29:40,527 INFO [main] org.apache.druid.cli.CliPeon - Starting up with processors [1], memory [1,037,959,168], maxMemory [1,037,959,168], directMemory [1,073,741,824]. Properties follow.
2023-10-05T09:29:40,528 INFO [main] org.apache.druid.cli.CliPeon - * attemptId: 1
2023-10-05T09:29:40,528 INFO [main] org.apache.druid.cli.CliPeon - * awt.toolkit: sun.awt.X11.XToolkit
2023-10-05T09:29:40,528 INFO [main] org.apache.druid.cli.CliPeon - * druid.emitter: noop
2023-10-05T09:29:40,529 INFO [main] org.apache.druid.cli.CliPeon - * druid.emitter.logging.logLevel: info
2023-10-05T09:29:40,529 INFO [main] org.apache.druid.cli.CliPeon - * druid.expressions.useStrictBooleans: true
2023-10-05T09:29:40,529 INFO [main] org.apache.druid.cli.CliPeon - * druid.extensions.loadList: ["druid-hdfs-storage", "druid-kafka-indexing-service", "druid-datasketches", "druid-multi-stage-query", "mysql-metadata-storage"]
2023-10-05T09:29:40,530 INFO [main] org.apache.druid.cli.CliPeon - * druid.global.http.eagerInitialization: false
2023-10-05T09:29:40,531 INFO [main] org.apache.druid.cli.CliPeon - * druid.host: 10.10.30.113
2023-10-05T09:29:40,531 INFO [main] org.apache.druid.cli.CliPeon - * druid.indexer.fork.property.druid.processing.buffer.sizeBytes: 100MiB
2023-10-05T09:29:40,531 INFO [main] org.apache.druid.cli.CliPeon - * druid.indexer.fork.property.druid.processing.numMergeBuffers: 2
2023-10-05T09:29:40,532 INFO [main] org.apache.druid.cli.CliPeon - * druid.indexer.fork.property.druid.processing.numThreads: 1
2023-10-05T09:29:40,532 INFO [main] org.apache.druid.cli.CliPeon - * druid.indexer.logs.directory: /data/deep/indexing-logs
2023-10-05T09:29:40,532 INFO [main] org.apache.druid.cli.CliPeon - * druid.indexer.logs.type: file
2023-10-05T09:29:40,533 INFO [main] org.apache.druid.cli.CliPeon - * druid.indexer.runner.javaCommand: bin/run-java
2023-10-05T09:29:40,533 INFO [main] org.apache.druid.cli.CliPeon - * druid.indexer.runner.javaOptsArray: ["-server","-Xms1g","-Xmx1g","-XX:MaxDirectMemorySize=1g","-Duser.timezone=UTC","-Dfile.encoding=UTF-8","-XX:+ExitOnOutOfMemoryError","-Djava.util.logging.manager=org.apache.logging.log4j.jul.LogManager"]
2023-10-05T09:29:40,534 INFO [main] org.apache.druid.cli.CliPeon - * druid.indexer.task.baseTaskDir: /data/druid/task
2023-10-05T09:29:40,534 INFO [main] org.apache.druid.cli.CliPeon - * druid.indexer.task.hadoopWorkingPath: /data/druid/hadoop-tmp
2023-10-05T09:29:40,535 INFO [main] org.apache.druid.cli.CliPeon - * druid.indexing.doubleStorage: double
2023-10-05T09:29:40,536 INFO [main] org.apache.druid.cli.CliPeon - * druid.log.path: /data/apache-druid-26.0.0/bin/../log
2023-10-05T09:29:40,536 INFO [main] org.apache.druid.cli.CliPeon - * druid.lookup.enableLookupSyncOnStartup: false
2023-10-05T09:29:40,537 INFO [main] org.apache.druid.cli.CliPeon - * druid.metadata.mysql.driver.driverClassName: org.mariadb.jdbc.Driver
2023-10-05T09:29:40,537 INFO [main] org.apache.druid.cli.CliPeon - * druid.metadata.storage.connector.connectURI: jdbc:mariadb://10.10.30.110:3306/druid
2023-10-05T09:29:40,537 INFO [main] org.apache.druid.cli.CliPeon - * druid.metadata.storage.connector.password: <masked>
2023-10-05T09:29:40,537 INFO [main] org.apache.druid.cli.CliPeon - * druid.metadata.storage.connector.user: druid
2023-10-05T09:29:40,538 INFO [main] org.apache.druid.cli.CliPeon - * druid.metadata.storage.type: mysql
2023-10-05T09:29:40,538 INFO [main] org.apache.druid.cli.CliPeon - * druid.metrics.emitter.dimension.dataSource: sms-test-data
2023-10-05T09:29:40,538 INFO [main] org.apache.druid.cli.CliPeon - * druid.metrics.emitter.dimension.taskId: index_kafka_sms-test-data_6656156d2ee944a_hdllhbmo
2023-10-05T09:29:40,538 INFO [main] org.apache.druid.cli.CliPeon - * druid.metrics.emitter.dimension.taskType: index_kafka
2023-10-05T09:29:40,538 INFO [main] org.apache.druid.cli.CliPeon - * druid.monitoring.monitors: ["org.apache.druid.java.util.metrics.JvmMonitor"]
2023-10-05T09:29:40,538 INFO [main] org.apache.druid.cli.CliPeon - * druid.node.type: middleManager
2023-10-05T09:29:40,539 INFO [main] org.apache.druid.cli.CliPeon - * druid.plaintextPort: 8100
2023-10-05T09:29:40,539 INFO [main] org.apache.druid.cli.CliPeon - * druid.processing.buffer.sizeBytes: 100MiB
2023-10-05T09:29:40,539 INFO [main] org.apache.druid.cli.CliPeon - * druid.processing.numMergeBuffers: 2
2023-10-05T09:29:40,539 INFO [main] org.apache.druid.cli.CliPeon - * druid.processing.numThreads: 1
2023-10-05T09:29:40,539 INFO [main] org.apache.druid.cli.CliPeon - * druid.selectors.coordinator.serviceName: druid/coordinator
2023-10-05T09:29:40,540 INFO [main] org.apache.druid.cli.CliPeon - * druid.selectors.indexing.serviceName: druid/overlord
2023-10-05T09:29:40,540 INFO [main] org.apache.druid.cli.CliPeon - * druid.server.hiddenProperties: ["druid.s3.accessKey","druid.s3.secretKey","druid.metadata.storage.connector.password", "password", "key", "token", "pwd"]
2023-10-05T09:29:40,540 INFO [main] org.apache.druid.cli.CliPeon - * druid.server.http.numThreads: 60
2023-10-05T09:29:40,540 INFO [main] org.apache.druid.cli.CliPeon - * druid.service: druid/middleManager
2023-10-05T09:29:40,540 INFO [main] org.apache.druid.cli.CliPeon - * druid.sql.enable: true
2023-10-05T09:29:40,541 INFO [main] org.apache.druid.cli.CliPeon - * druid.sql.planner.useGroupingSetForExactDistinct: true
2023-10-05T09:29:40,541 INFO [main] org.apache.druid.cli.CliPeon - * druid.startup.logging.logProperties: true
2023-10-05T09:29:40,541 INFO [main] org.apache.druid.cli.CliPeon - * druid.storage.storageDirectory: /data/deep/segments
2023-10-05T09:29:40,541 INFO [main] org.apache.druid.cli.CliPeon - * druid.storage.type: local
2023-10-05T09:29:40,542 INFO [main] org.apache.druid.cli.CliPeon - * druid.task.executor.enablePlaintextPort: true
2023-10-05T09:29:40,542 INFO [main] org.apache.druid.cli.CliPeon - * druid.task.executor.enableTlsPort: false
2023-10-05T09:29:40,542 INFO [main] org.apache.druid.cli.CliPeon - * druid.task.executor.host: 10.10.30.113
2023-10-05T09:29:40,543 INFO [main] org.apache.druid.cli.CliPeon - * druid.task.executor.plaintextPort: 8091
2023-10-05T09:29:40,543 INFO [main] org.apache.druid.cli.CliPeon - * druid.task.executor.service: druid/middleManager
2023-10-05T09:29:40,543 INFO [main] org.apache.druid.cli.CliPeon - * druid.task.executor.tlsPort: -1
2023-10-05T09:29:40,543 INFO [main] org.apache.druid.cli.CliPeon - * druid.tlsPort: -1
2023-10-05T09:29:40,544 INFO [main] org.apache.druid.cli.CliPeon - * druid.worker.baseTaskDirs: ["/data/druid/task"]
2023-10-05T09:29:40,544 INFO [main] org.apache.druid.cli.CliPeon - * druid.worker.capacity: 4
2023-10-05T09:29:40,544 INFO [main] org.apache.druid.cli.CliPeon - * druid.zk.paths.base: /data/zk
2023-10-05T09:29:40,544 INFO [main] org.apache.druid.cli.CliPeon - * druid.zk.service.host: 10.10.30.110:2181
2023-10-05T09:29:40,544 INFO [main] org.apache.druid.cli.CliPeon - * file.encoding: UTF-8
2023-10-05T09:29:40,544 INFO [main] org.apache.druid.cli.CliPeon - * file.separator: /
2023-10-05T09:29:40,545 INFO [main] org.apache.druid.cli.CliPeon - * java.awt.graphicsenv: sun.awt.X11GraphicsEnvironment
2023-10-05T09:29:40,545 INFO [main] org.apache.druid.cli.CliPeon - * java.awt.printerjob: sun.print.PSPrinterJob
2023-10-05T09:29:40,545 INFO [main] org.apache.druid.cli.CliPeon - * java.class.path: /data/apache-druid-26.0.0/conf/druid/cluster/data/middleManager:/data/apache-druid-26.0.0/conf/druid/cluster/data/_common:/data/apache-druid-26.0.0/conf/druid/cluster/data/_common/hadoop-xml:/data/apache-druid-26.0.0/conf/druid/cluster/data/../_common:/data/apache-druid-26.0.0/conf/druid/cluster/data/../_common/hadoop-xml:/data/apache-druid-26.0.0/bin/../lib/aws-java-sdk-ec2-1.12.317.jar:/data/apache-druid-26.0.0/bin/../lib/jaxb-api-2.3.1.jar:/data/apache-druid-26.0.0/bin/../lib/jersey-guice-1.19.4.jar:/data/apache-druid-26.0.0/bin/../lib/commons-beanutils-1.9.4.jar:/data/apache-druid-26.0.0/bin/../lib/antlr4-runtime-4.5.1.jar:/data/apache-druid-26.0.0/bin/../lib/jcodings-1.0.43.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-annotations-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/ion-java-1.0.2.jar:/data/apache-druid-26.0.0/bin/../lib/async-http-client-2.5.3.jar:/data/apache-druid-26.0.0/bin/../lib/checker-qual-2.5.7.jar:/data/apache-druid-26.0.0/bin/../lib/jna-4.5.1.jar:/data/apache-druid-26.0.0/bin/../lib/web-console-26.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/shims-0.9.0.jar:/data/apache-druid-26.0.0/bin/../lib/netty-codec-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/google-oauth-client-1.26.0.jar:/data/apache-druid-26.0.0/bin/../lib/javax.inject-1.jar:/data/apache-druid-26.0.0/bin/../lib/vavr-match-0.10.2.jar:/data/apache-druid-26.0.0/bin/../lib/druid-indexing-hadoop-26.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/aws-java-sdk-s3-1.12.317.jar:/data/apache-druid-26.0.0/bin/../lib/protobuf-java-3.21.7.jar:/data/apache-druid-26.0.0/bin/../lib/aether-connector-okhttp-0.0.9.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-dataformat-smile-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-jq-0.0.10.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-io-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/asm-commons-9.3.jar:/data/apache-druid-26.0.0/bin/../lib/json-path-2.3.0.jar:/data/apache-druid-26.0.0/bin/../lib/compress-lzf-1.0.4.jar:/data/apache-druid-26.0.0/bin/../lib/hibernate-validator-5.2.5.Final.jar:/data/apache-druid-26.0.0/bin/../lib/reactive-streams-1.0.2.jar:/data/apache-druid-26.0.0/bin/../lib/javax.activation-api-1.2.0.jar:/data/apache-druid-26.0.0/bin/../lib/maven-model-3.1.1.jar:/data/apache-druid-26.0.0/bin/../lib/guice-4.1.0.jar:/data/apache-druid-26.0.0/bin/../lib/airline-2.8.4.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-core-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/maven-settings-builder-3.1.1.jar:/data/apache-druid-26.0.0/bin/../lib/lz4-java-1.8.0.jar:/data/apache-druid-26.0.0/bin/../lib/aws-java-sdk-sts-1.12.317.jar:/data/apache-druid-26.0.0/bin/../lib/curator-framework-5.4.0.jar:/data/apache-druid-26.0.0/bin/../lib/aether-impl-0.9.0.M2.jar:/data/apache-druid-26.0.0/bin/../lib/okhttp-1.0.2.jar:/data/apache-druid-26.0.0/bin/../lib/druid-processing-26.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-http-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-jaxrs-json-provider-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/istack-commons-runtime-3.0.7.jar:/data/apache-druid-26.0.0/bin/../lib/aopalliance-1.0.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-databind-2.10.5.1.jar:/data/apache-druid-26.0.0/bin/../lib/datasketches-memory-2.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/ipaddress-5.3.4.jar:/data/apache-druid-26.0.0/bin/../lib/jsr311-api-1.1.1.jar:/data/apache-druid-26.0.0/bin/../lib/metrics-core-4.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-rewrite-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/log4j-api-2.18.0.jar:/data/apache-druid-26.0.0/bin/../lib/avatica-server-1.17.0.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-security-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/netty-transport-classes-epoll-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/datasketches-java-3.2.0.jar:/data/apache-druid-26.0.0/bin/../lib/netty-common-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/commons-logging-1.1.1.jar:/data/apache-druid-26.0.0/bin/../lib/httpcore-4.4.11.jar:/data/apache-druid-26.0.0/bin/../lib/log4j-slf4j-impl-2.18.0.jar:/data/apache-druid-26.0.0/bin/../lib/commons-dbcp2-2.0.1.jar:/data/apache-druid-26.0.0/bin/../lib/google-http-client-1.26.0.jar:/data/apache-druid-26.0.0/bin/../lib/netty-handler-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/netty-handler-proxy-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/validation-api-1.1.0.Final.jar:/data/apache-druid-26.0.0/bin/../lib/curator-recipes-5.4.0.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-continuation-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/joni-2.1.27.jar:/data/apache-druid-26.0.0/bin/../lib/jersey-server-1.19.4.jar:/data/apache-druid-26.0.0/bin/../lib/httpclient-4.5.13.jar:/data/apache-druid-26.0.0/bin/../lib/icu4j-55.1.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-client-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/fastutil-core-8.5.4.jar:/data/apache-druid-26.0.0/bin/../lib/maven-artifact-3.6.0.jar:/data/apache-druid-26.0.0/bin/../lib/classmate-1.1.0.jar:/data/apache-druid-26.0.0/bin/../lib/log4j-jul-2.18.0.jar:/data/apache-druid-26.0.0/bin/../lib/jersey-core-1.19.4.jar:/data/apache-druid-26.0.0/bin/../lib/accessors-smart-1.2.jar:/data/apache-druid-26.0.0/bin/../lib/jdbi-2.63.1.jar:/data/apache-druid-26.0.0/bin/../lib/aether-spi-0.9.0.M2.jar:/data/apache-druid-26.0.0/bin/../lib/jboss-logging-3.2.1.Final.jar:/data/apache-druid-26.0.0/bin/../lib/aws-java-sdk-kms-1.12.317.jar:/data/apache-druid-26.0.0/bin/../lib/jsr305-2.0.1.jar:/data/apache-druid-26.0.0/bin/../lib/jakarta.el-3.0.4.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-jaxrs-smile-provider-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/netty-resolver-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/spymemcached-2.12.3.jar:/data/apache-druid-26.0.0/bin/../lib/jmespath-java-1.12.317.jar:/data/apache-druid-26.0.0/bin/../lib/calcite-linq4j-1.21.0.jar:/data/apache-druid-26.0.0/bin/../lib/commons-codec-1.13.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-util-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/curator-x-discovery-5.4.0.jar:/data/apache-druid-26.0.0/bin/../lib/commons-text-1.10.0.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-servlet-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/commons-io-2.11.0.jar:/data/apache-druid-26.0.0/bin/../lib/jaxb-runtime-2.3.1.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-module-jaxb-annotations-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/druid-indexing-service-26.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/log4j-1.2-api-2.18.0.jar:/data/apache-druid-26.0.0/bin/../lib/aggdesigner-algorithm-6.0.jar:/data/apache-druid-26.0.0/bin/../lib/config-magic-0.9.jar:/data/apache-druid-26.0.0/bin/../lib/zookeeper-jute-3.5.10.jar:/data/apache-druid-26.0.0/bin/../lib/commons-math3-3.6.1.jar:/data/apache-druid-26.0.0/bin/../lib/RoaringBitmap-0.9.0.jar:/data/apache-druid-26.0.0/bin/../lib/fastutil-8.5.4.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-jaxrs-base-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/maven-settings-3.1.1.jar:/data/apache-druid-26.0.0/bin/../lib/netty-transport-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/slf4j-api-1.7.36.jar:/data/apache-druid-26.0.0/bin/../lib/maven-model-builder-3.1.1.jar:/data/apache-druid-26.0.0/bin/../lib/tesla-aether-0.0.5.jar:/data/apache-druid-26.0.0/bin/../lib/netty-transport-native-epoll-4.1.86.Final-linux-x86_64.jar:/data/apache-druid-26.0.0/bin/../lib/avatica-metrics-1.17.0.jar:/data/apache-druid-26.0.0/bin/../lib/calcite-core-1.21.0.jar:/data/apache-druid-26.0.0/bin/../lib/jakarta.xml.bind-api-2.3.2.jar:/data/apache-druid-26.0.0/bin/../lib/curator-client-5.4.0.jar:/data/apache-druid-26.0.0/bin/../lib/netty-buffer-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/netty-codec-dns-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/google-http-client-jackson2-1.26.0.jar:/data/apache-druid-26.0.0/bin/../lib/druid-services-26.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/druid-sql-26.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/javax.servlet-api-3.1.0.jar:/data/apache-druid-26.0.0/bin/../lib/aether-api-0.9.0.M2.jar:/data/apache-druid-26.0.0/bin/../lib/resilience4j-core-1.3.1.jar:/data/apache-druid-26.0.0/bin/../lib/janino-3.0.11.jar:/data/apache-druid-26.0.0/bin/../lib/netty-codec-http-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/zookeeper-3.5.10.jar:/data/apache-druid-26.0.0/bin/../lib/joda-time-2.12.4.jar:/data/apache-druid-26.0.0/bin/../lib/commons-collections4-4.2.jar:/data/apache-druid-26.0.0/bin/../lib/guice-assistedinject-4.1.0.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-server-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/jcl-over-slf4j-1.7.36.jar:/data/apache-druid-26.0.0/bin/../lib/derbynet-10.14.2.0.jar:/data/apache-druid-26.0.0/bin/../lib/esri-geometry-api-2.2.0.jar:/data/apache-druid-26.0.0/bin/../lib/netty-codec-socks-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/commons-pool2-2.2.jar:/data/apache-druid-26.0.0/bin/../lib/commons-compiler-3.0.11.jar:/data/apache-druid-26.0.0/bin/../lib/netty-resolver-dns-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/avatica-core-1.17.0.jar:/data/apache-druid-26.0.0/bin/../lib/txw2-2.3.1.jar:/data/apache-druid-26.0.0/bin/../lib/jakarta.activation-api-1.2.1.jar:/data/apache-druid-26.0.0/bin/../lib/netty-transport-native-unix-common-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/javax.activation-1.2.0.jar:/data/apache-druid-26.0.0/bin/../lib/airline-io-2.8.4.jar:/data/apache-druid-26.0.0/bin/../lib/commons-compress-1.21.jar:/data/apache-druid-26.0.0/bin/../lib/guava-16.0.1.jar:/data/apache-druid-26.0.0/bin/../lib/plexus-utils-3.0.24.jar:/data/apache-druid-26.0.0/bin/../lib/vavr-0.10.2.jar:/data/apache-druid-26.0.0/bin/../lib/resilience4j-bulkhead-1.3.1.jar:/data/apache-druid-26.0.0/bin/../lib/maven-aether-provider-3.1.1.jar:/data/apache-druid-26.0.0/bin/../lib/asm-tree-9.3.jar:/data/apache-druid-26.0.0/bin/../lib/google-api-client-1.26.0.jar:/data/apache-druid-26.0.0/bin/../lib/commons-lang-2.6.jar:/data/apache-druid-26.0.0/bin/../lib/wagon-provider-api-2.4.jar:/data/apache-druid-26.0.0/bin/../lib/druid-gcp-common-26.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-module-guice-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/aether-util-0.9.0.M2.jar:/data/apache-druid-26.0.0/bin/../lib/opencsv-4.6.jar:/data/apache-druid-26.0.0/bin/../lib/stax-ex-1.8.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-datatype-guava-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/guice-servlet-4.1.0.jar:/data/apache-druid-26.0.0/bin/../lib/log4j-core-2.18.0.jar:/data/apache-druid-26.0.0/bin/../lib/j2objc-annotations-1.1.jar:/data/apache-druid-26.0.0/bin/../lib/commons-collections-3.2.2.jar:/data/apache-druid-26.0.0/bin/../lib/json-smart-2.3.jar:/data/apache-druid-26.0.0/bin/../lib/guice-multibindings-4.1.0.jar:/data/apache-druid-26.0.0/bin/../lib/error_prone_annotations-2.11.0.jar:/data/apache-druid-26.0.0/bin/../lib/cron-scheduler-0.1.jar:/data/apache-druid-26.0.0/bin/../lib/derby-10.14.2.0.jar:/data/apache-druid-26.0.0/bin/../lib/netty-reactive-streams-2.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/druid-server-26.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/derbyclient-10.14.2.0.jar:/data/apache-druid-26.0.0/bin/../lib/asm-9.3.jar:/data/apache-druid-26.0.0/bin/../lib/druid-aws-common-26.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/rhino-1.7.11.jar:/data/apache-druid-26.0.0/bin/../lib/disruptor-3.3.6.jar:/data/apache-druid-26.0.0/bin/../lib/xz-1.8.jar:/data/apache-druid-26.0.0/bin/../lib/FastInfoset-1.2.15.jar:/data/apache-druid-26.0.0/bin/../lib/asm-analysis-9.3.jar:/data/apache-druid-26.0.0/bin/../lib/zstd-jni-1.5.2-3.jar:/data/apache-druid-26.0.0/bin/../lib/async-http-client-netty-utils-2.5.3.jar:/data/apache-druid-26.0.0/bin/../lib/netty-3.10.6.Final.jar:/data/apache-druid-26.0.0/bin/../lib/plexus-interpolation-1.19.jar:/data/apache-druid-26.0.0/bin/../lib/javax.el-api-3.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-servlets-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-datatype-joda-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/fastutil-extra-8.5.4.jar:/data/apache-druid-26.0.0/bin/../lib/caffeine-2.8.0.jar:/data/apache-druid-26.0.0/bin/../lib/audience-annotations-0.5.0.jar:/data/apache-druid-26.0.0/bin/../lib/commons-lang3-3.12.0.jar:/data/apache-druid-26.0.0/bin/../lib/jersey-servlet-1.19.4.jar:/data/apache-druid-26.0.0/bin/../lib/sigar-1.6.5.132.jar:/data/apache-druid-26.0.0/bin/../lib/maven-repository-metadata-3.1.1.jar:/data/apache-druid-26.0.0/bin/../lib/jakarta.inject-api-1.0.3.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-util-ajax-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-dataformat-cbor-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/aws-java-sdk-core-1.12.317.jar:/data/apache-druid-26.0.0/bin/../lib/aether-connector-file-0.9.0.M2.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-proxy-9.4.48.v20220622.jar
2023-10-05T09:29:40,545 INFO [main] org.apache.druid.cli.CliPeon - * java.class.version: 55.0
2023-10-05T09:29:40,546 INFO [main] org.apache.druid.cli.CliPeon - * java.home: /usr/lib/jvm/java-11-openjdk-amd64
2023-10-05T09:29:40,546 INFO [main] org.apache.druid.cli.CliPeon - * java.io.tmpdir: var/tmp
2023-10-05T09:29:40,547 INFO [main] org.apache.druid.cli.CliPeon - * java.library.path: /usr/java/packages/lib:/usr/lib/x86_64-linux-gnu/jni:/lib/x86_64-linux-gnu:/usr/lib/x86_64-linux-gnu:/usr/lib/jni:/lib:/usr/lib
2023-10-05T09:29:40,547 INFO [main] org.apache.druid.cli.CliPeon - * java.runtime.name: OpenJDK Runtime Environment
2023-10-05T09:29:40,547 INFO [main] org.apache.druid.cli.CliPeon - * java.runtime.version: 11.0.18+10-post-Debian-1deb11u1
2023-10-05T09:29:40,547 INFO [main] org.apache.druid.cli.CliPeon - * java.specification.name: Java Platform API Specification
2023-10-05T09:29:40,548 INFO [main] org.apache.druid.cli.CliPeon - * java.specification.vendor: Oracle Corporation
2023-10-05T09:29:40,548 INFO [main] org.apache.druid.cli.CliPeon - * java.specification.version: 11
2023-10-05T09:29:40,548 INFO [main] org.apache.druid.cli.CliPeon - * java.util.logging.manager: org.apache.logging.log4j.jul.LogManager
2023-10-05T09:29:40,549 INFO [main] org.apache.druid.cli.CliPeon - * java.vendor: Debian
2023-10-05T09:29:40,550 INFO [main] org.apache.druid.cli.CliPeon - * java.vendor.url: https://tracker.debian.org/openjdk-11
2023-10-05T09:29:40,551 INFO [main] org.apache.druid.cli.CliPeon - * java.vendor.url.bug: https://bugs.debian.org/openjdk-11
2023-10-05T09:29:40,551 INFO [main] org.apache.druid.cli.CliPeon - * java.version: 11.0.18
2023-10-05T09:29:40,552 INFO [main] org.apache.druid.cli.CliPeon - * java.version.date: 2023-01-17
2023-10-05T09:29:40,552 INFO [main] org.apache.druid.cli.CliPeon - * java.vm.compressedOopsMode: 32-bit
2023-10-05T09:29:40,552 INFO [main] org.apache.druid.cli.CliPeon - * java.vm.info: mixed mode, sharing
2023-10-05T09:29:40,552 INFO [main] org.apache.druid.cli.CliPeon - * java.vm.name: OpenJDK 64-Bit Server VM
2023-10-05T09:29:40,552 INFO [main] org.apache.druid.cli.CliPeon - * java.vm.specification.name: Java Virtual Machine Specification
2023-10-05T09:29:40,553 INFO [main] org.apache.druid.cli.CliPeon - * java.vm.specification.vendor: Oracle Corporation
2023-10-05T09:29:40,554 INFO [main] org.apache.druid.cli.CliPeon - * java.vm.specification.version: 11
2023-10-05T09:29:40,555 INFO [main] org.apache.druid.cli.CliPeon - * java.vm.vendor: Debian
2023-10-05T09:29:40,556 INFO [main] org.apache.druid.cli.CliPeon - * java.vm.version: 11.0.18+10-post-Debian-1deb11u1
2023-10-05T09:29:40,556 INFO [main] org.apache.druid.cli.CliPeon - * jdk.debug: release
2023-10-05T09:29:40,556 INFO [main] org.apache.druid.cli.CliPeon - * line.separator:
2023-10-05T09:29:40,556 INFO [main] org.apache.druid.cli.CliPeon - * log4j.shutdownCallbackRegistry: org.apache.druid.common.config.Log4jShutdown
2023-10-05T09:29:40,559 INFO [main] org.apache.druid.cli.CliPeon - * log4j.shutdownHookEnabled: true
2023-10-05T09:29:40,560 INFO [main] org.apache.druid.cli.CliPeon - * log4j2.configurationFactory: org.apache.druid.indexing.common.tasklogs.ConsoleLoggingEnforcementConfigurationFactory
2023-10-05T09:29:40,560 INFO [main] org.apache.druid.cli.CliPeon - * log4j2.is.webapp: false
2023-10-05T09:29:40,560 INFO [main] org.apache.druid.cli.CliPeon - * os.arch: amd64
2023-10-05T09:29:40,560 INFO [main] org.apache.druid.cli.CliPeon - * os.name: Linux
2023-10-05T09:29:40,561 INFO [main] org.apache.druid.cli.CliPeon - * os.version: 5.10.0-22-amd64
2023-10-05T09:29:40,562 INFO [main] org.apache.druid.cli.CliPeon - * path.separator: :
2023-10-05T09:29:40,562 INFO [main] org.apache.druid.cli.CliPeon - * sun.arch.data.model: 64
2023-10-05T09:29:40,562 INFO [main] org.apache.druid.cli.CliPeon - * sun.boot.library.path: /usr/lib/jvm/java-11-openjdk-amd64/lib
2023-10-05T09:29:40,562 INFO [main] org.apache.druid.cli.CliPeon - * sun.cpu.endian: little
2023-10-05T09:29:40,562 INFO [main] org.apache.druid.cli.CliPeon - * sun.cpu.isalist:
2023-10-05T09:29:40,562 INFO [main] org.apache.druid.cli.CliPeon - * sun.io.unicode.encoding: UnicodeLittle
2023-10-05T09:29:40,563 INFO [main] org.apache.druid.cli.CliPeon - * sun.java.command: org.apache.druid.cli.Main internal peon /data/druid/task/index_kafka_sms-test-data_6656156d2ee944a_hdllhbmo 1 --loadBroadcastSegments true
2023-10-05T09:29:40,563 INFO [main] org.apache.druid.cli.CliPeon - * sun.java.launcher: SUN_STANDARD
2023-10-05T09:29:40,563 INFO [main] org.apache.druid.cli.CliPeon - * sun.jnu.encoding: UTF-8
2023-10-05T09:29:40,563 INFO [main] org.apache.druid.cli.CliPeon - * sun.management.compiler: HotSpot 64-Bit Tiered Compilers
2023-10-05T09:29:40,564 INFO [main] org.apache.druid.cli.CliPeon - * sun.os.patch.level: unknown
2023-10-05T09:29:40,564 INFO [main] org.apache.druid.cli.CliPeon - * user.country: US
2023-10-05T09:29:40,564 INFO [main] org.apache.druid.cli.CliPeon - * user.dir: /data/apache-druid-26.0.0
2023-10-05T09:29:40,564 INFO [main] org.apache.druid.cli.CliPeon - * user.home: /root
2023-10-05T09:29:40,564 INFO [main] org.apache.druid.cli.CliPeon - * user.language: en
2023-10-05T09:29:40,565 INFO [main] org.apache.druid.cli.CliPeon - * user.name: root
2023-10-05T09:29:40,565 INFO [main] org.apache.druid.cli.CliPeon - * user.timezone: UTC
2023-10-05T09:29:40,607 WARN [main] org.apache.druid.indexing.common.config.TaskConfig - Batch processing mode argument value is null or not valid:[null], defaulting to[CLOSED_SEGMENTS]
2023-10-05T09:29:41,097 INFO [main] org.apache.druid.segment.loading.SegmentLocalCacheManager - Using storage location strategy: [LeastBytesUsedStorageLocationSelectorStrategy]
2023-10-05T09:29:41,166 INFO [main] org.apache.druid.guice.StorageNodeModule - Segment cache not configured on ServerType [indexer-executor]. It will not be assignable for segment placement
2023-10-05T09:29:41,270 INFO [main] org.eclipse.jetty.util.log - Logging initialized @7504ms to org.eclipse.jetty.util.log.Slf4jLog
2023-10-05T09:29:41,287 INFO [main] org.apache.druid.server.initialization.jetty.JettyServerModule - Creating http connector with port [8100]
2023-10-05T09:29:41,426 WARN [main] org.eclipse.jetty.server.handler.gzip.GzipHandler - minGzipSize of 0 is inefficient for short content, break even is size 23
2023-10-05T09:29:41,460 INFO [main] org.apache.druid.offheap.OffheapBufferGenerator - Allocating new intermediate processing buffer[0] of size[104,857,600]
2023-10-05T09:29:41,559 INFO [main] org.apache.druid.offheap.OffheapBufferGenerator - Allocating new result merging buffer[0] of size[104,857,600]
2023-10-05T09:29:41,598 INFO [main] org.apache.druid.offheap.OffheapBufferGenerator - Allocating new result merging buffer[1] of size[104,857,600]
2023-10-05T09:29:41,705 INFO [main] org.apache.druid.java.util.common.lifecycle.Lifecycle - Starting lifecycle [module] stage [INIT]
2023-10-05T09:29:41,706 INFO [main] org.apache.druid.java.util.common.lifecycle.Lifecycle - Starting lifecycle [module] stage [NORMAL]
2023-10-05T09:29:41,720 INFO [main] org.apache.curator.framework.imps.CuratorFrameworkImpl - Starting
2023-10-05T09:29:41,732 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:zookeeper.version=3.5.10-a32c7183d42325b03e44a06aade6a0f16955bf13, built on 05/29/2022 16:59 GMT
2023-10-05T09:29:41,734 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:host.name=druid-data-clone.allip.local
2023-10-05T09:29:41,735 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:java.version=11.0.18
2023-10-05T09:29:41,735 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:java.vendor=Debian
2023-10-05T09:29:41,735 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:java.home=/usr/lib/jvm/java-11-openjdk-amd64
2023-10-05T09:29:41,735 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:java.class.path=/data/apache-druid-26.0.0/conf/druid/cluster/data/middleManager:/data/apache-druid-26.0.0/conf/druid/cluster/data/_common:/data/apache-druid-26.0.0/conf/druid/cluster/data/_common/hadoop-xml:/data/apache-druid-26.0.0/conf/druid/cluster/data/../_common:/data/apache-druid-26.0.0/conf/druid/cluster/data/../_common/hadoop-xml:/data/apache-druid-26.0.0/bin/../lib/aws-java-sdk-ec2-1.12.317.jar:/data/apache-druid-26.0.0/bin/../lib/jaxb-api-2.3.1.jar:/data/apache-druid-26.0.0/bin/../lib/jersey-guice-1.19.4.jar:/data/apache-druid-26.0.0/bin/../lib/commons-beanutils-1.9.4.jar:/data/apache-druid-26.0.0/bin/../lib/antlr4-runtime-4.5.1.jar:/data/apache-druid-26.0.0/bin/../lib/jcodings-1.0.43.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-annotations-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/ion-java-1.0.2.jar:/data/apache-druid-26.0.0/bin/../lib/async-http-client-2.5.3.jar:/data/apache-druid-26.0.0/bin/../lib/checker-qual-2.5.7.jar:/data/apache-druid-26.0.0/bin/../lib/jna-4.5.1.jar:/data/apache-druid-26.0.0/bin/../lib/web-console-26.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/shims-0.9.0.jar:/data/apache-druid-26.0.0/bin/../lib/netty-codec-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/google-oauth-client-1.26.0.jar:/data/apache-druid-26.0.0/bin/../lib/javax.inject-1.jar:/data/apache-druid-26.0.0/bin/../lib/vavr-match-0.10.2.jar:/data/apache-druid-26.0.0/bin/../lib/druid-indexing-hadoop-26.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/aws-java-sdk-s3-1.12.317.jar:/data/apache-druid-26.0.0/bin/../lib/protobuf-java-3.21.7.jar:/data/apache-druid-26.0.0/bin/../lib/aether-connector-okhttp-0.0.9.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-dataformat-smile-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-jq-0.0.10.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-io-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/asm-commons-9.3.jar:/data/apache-druid-26.0.0/bin/../lib/json-path-2.3.0.jar:/data/apache-druid-26.0.0/bin/../lib/compress-lzf-1.0.4.jar:/data/apache-druid-26.0.0/bin/../lib/hibernate-validator-5.2.5.Final.jar:/data/apache-druid-26.0.0/bin/../lib/reactive-streams-1.0.2.jar:/data/apache-druid-26.0.0/bin/../lib/javax.activation-api-1.2.0.jar:/data/apache-druid-26.0.0/bin/../lib/maven-model-3.1.1.jar:/data/apache-druid-26.0.0/bin/../lib/guice-4.1.0.jar:/data/apache-druid-26.0.0/bin/../lib/airline-2.8.4.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-core-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/maven-settings-builder-3.1.1.jar:/data/apache-druid-26.0.0/bin/../lib/lz4-java-1.8.0.jar:/data/apache-druid-26.0.0/bin/../lib/aws-java-sdk-sts-1.12.317.jar:/data/apache-druid-26.0.0/bin/../lib/curator-framework-5.4.0.jar:/data/apache-druid-26.0.0/bin/../lib/aether-impl-0.9.0.M2.jar:/data/apache-druid-26.0.0/bin/../lib/okhttp-1.0.2.jar:/data/apache-druid-26.0.0/bin/../lib/druid-processing-26.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-http-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-jaxrs-json-provider-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/istack-commons-runtime-3.0.7.jar:/data/apache-druid-26.0.0/bin/../lib/aopalliance-1.0.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-databind-2.10.5.1.jar:/data/apache-druid-26.0.0/bin/../lib/datasketches-memory-2.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/ipaddress-5.3.4.jar:/data/apache-druid-26.0.0/bin/../lib/jsr311-api-1.1.1.jar:/data/apache-druid-26.0.0/bin/../lib/metrics-core-4.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-rewrite-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/log4j-api-2.18.0.jar:/data/apache-druid-26.0.0/bin/../lib/avatica-server-1.17.0.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-security-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/netty-transport-classes-epoll-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/datasketches-java-3.2.0.jar:/data/apache-druid-26.0.0/bin/../lib/netty-common-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/commons-logging-1.1.1.jar:/data/apache-druid-26.0.0/bin/../lib/httpcore-4.4.11.jar:/data/apache-druid-26.0.0/bin/../lib/log4j-slf4j-impl-2.18.0.jar:/data/apache-druid-26.0.0/bin/../lib/commons-dbcp2-2.0.1.jar:/data/apache-druid-26.0.0/bin/../lib/google-http-client-1.26.0.jar:/data/apache-druid-26.0.0/bin/../lib/netty-handler-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/netty-handler-proxy-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/validation-api-1.1.0.Final.jar:/data/apache-druid-26.0.0/bin/../lib/curator-recipes-5.4.0.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-continuation-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/joni-2.1.27.jar:/data/apache-druid-26.0.0/bin/../lib/jersey-server-1.19.4.jar:/data/apache-druid-26.0.0/bin/../lib/httpclient-4.5.13.jar:/data/apache-druid-26.0.0/bin/../lib/icu4j-55.1.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-client-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/fastutil-core-8.5.4.jar:/data/apache-druid-26.0.0/bin/../lib/maven-artifact-3.6.0.jar:/data/apache-druid-26.0.0/bin/../lib/classmate-1.1.0.jar:/data/apache-druid-26.0.0/bin/../lib/log4j-jul-2.18.0.jar:/data/apache-druid-26.0.0/bin/../lib/jersey-core-1.19.4.jar:/data/apache-druid-26.0.0/bin/../lib/accessors-smart-1.2.jar:/data/apache-druid-26.0.0/bin/../lib/jdbi-2.63.1.jar:/data/apache-druid-26.0.0/bin/../lib/aether-spi-0.9.0.M2.jar:/data/apache-druid-26.0.0/bin/../lib/jboss-logging-3.2.1.Final.jar:/data/apache-druid-26.0.0/bin/../lib/aws-java-sdk-kms-1.12.317.jar:/data/apache-druid-26.0.0/bin/../lib/jsr305-2.0.1.jar:/data/apache-druid-26.0.0/bin/../lib/jakarta.el-3.0.4.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-jaxrs-smile-provider-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/netty-resolver-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/spymemcached-2.12.3.jar:/data/apache-druid-26.0.0/bin/../lib/jmespath-java-1.12.317.jar:/data/apache-druid-26.0.0/bin/../lib/calcite-linq4j-1.21.0.jar:/data/apache-druid-26.0.0/bin/../lib/commons-codec-1.13.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-util-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/curator-x-discovery-5.4.0.jar:/data/apache-druid-26.0.0/bin/../lib/commons-text-1.10.0.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-servlet-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/commons-io-2.11.0.jar:/data/apache-druid-26.0.0/bin/../lib/jaxb-runtime-2.3.1.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-module-jaxb-annotations-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/druid-indexing-service-26.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/log4j-1.2-api-2.18.0.jar:/data/apache-druid-26.0.0/bin/../lib/aggdesigner-algorithm-6.0.jar:/data/apache-druid-26.0.0/bin/../lib/config-magic-0.9.jar:/data/apache-druid-26.0.0/bin/../lib/zookeeper-jute-3.5.10.jar:/data/apache-druid-26.0.0/bin/../lib/commons-math3-3.6.1.jar:/data/apache-druid-26.0.0/bin/../lib/RoaringBitmap-0.9.0.jar:/data/apache-druid-26.0.0/bin/../lib/fastutil-8.5.4.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-jaxrs-base-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/maven-settings-3.1.1.jar:/data/apache-druid-26.0.0/bin/../lib/netty-transport-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/slf4j-api-1.7.36.jar:/data/apache-druid-26.0.0/bin/../lib/maven-model-builder-3.1.1.jar:/data/apache-druid-26.0.0/bin/../lib/tesla-aether-0.0.5.jar:/data/apache-druid-26.0.0/bin/../lib/netty-transport-native-epoll-4.1.86.Final-linux-x86_64.jar:/data/apache-druid-26.0.0/bin/../lib/avatica-metrics-1.17.0.jar:/data/apache-druid-26.0.0/bin/../lib/calcite-core-1.21.0.jar:/data/apache-druid-26.0.0/bin/../lib/jakarta.xml.bind-api-2.3.2.jar:/data/apache-druid-26.0.0/bin/../lib/curator-client-5.4.0.jar:/data/apache-druid-26.0.0/bin/../lib/netty-buffer-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/netty-codec-dns-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/google-http-client-jackson2-1.26.0.jar:/data/apache-druid-26.0.0/bin/../lib/druid-services-26.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/druid-sql-26.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/javax.servlet-api-3.1.0.jar:/data/apache-druid-26.0.0/bin/../lib/aether-api-0.9.0.M2.jar:/data/apache-druid-26.0.0/bin/../lib/resilience4j-core-1.3.1.jar:/data/apache-druid-26.0.0/bin/../lib/janino-3.0.11.jar:/data/apache-druid-26.0.0/bin/../lib/netty-codec-http-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/zookeeper-3.5.10.jar:/data/apache-druid-26.0.0/bin/../lib/joda-time-2.12.4.jar:/data/apache-druid-26.0.0/bin/../lib/commons-collections4-4.2.jar:/data/apache-druid-26.0.0/bin/../lib/guice-assistedinject-4.1.0.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-server-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/jcl-over-slf4j-1.7.36.jar:/data/apache-druid-26.0.0/bin/../lib/derbynet-10.14.2.0.jar:/data/apache-druid-26.0.0/bin/../lib/esri-geometry-api-2.2.0.jar:/data/apache-druid-26.0.0/bin/../lib/netty-codec-socks-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/commons-pool2-2.2.jar:/data/apache-druid-26.0.0/bin/../lib/commons-compiler-3.0.11.jar:/data/apache-druid-26.0.0/bin/../lib/netty-resolver-dns-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/avatica-core-1.17.0.jar:/data/apache-druid-26.0.0/bin/../lib/txw2-2.3.1.jar:/data/apache-druid-26.0.0/bin/../lib/jakarta.activation-api-1.2.1.jar:/data/apache-druid-26.0.0/bin/../lib/netty-transport-native-unix-common-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/javax.activation-1.2.0.jar:/data/apache-druid-26.0.0/bin/../lib/airline-io-2.8.4.jar:/data/apache-druid-26.0.0/bin/../lib/commons-compress-1.21.jar:/data/apache-druid-26.0.0/bin/../lib/guava-16.0.1.jar:/data/apache-druid-26.0.0/bin/../lib/plexus-utils-3.0.24.jar:/data/apache-druid-26.0.0/bin/../lib/vavr-0.10.2.jar:/data/apache-druid-26.0.0/bin/../lib/resilience4j-bulkhead-1.3.1.jar:/data/apache-druid-26.0.0/bin/../lib/maven-aether-provider-3.1.1.jar:/data/apache-druid-26.0.0/bin/../lib/asm-tree-9.3.jar:/data/apache-druid-26.0.0/bin/../lib/google-api-client-1.26.0.jar:/data/apache-druid-26.0.0/bin/../lib/commons-lang-2.6.jar:/data/apache-druid-26.0.0/bin/../lib/wagon-provider-api-2.4.jar:/data/apache-druid-26.0.0/bin/../lib/druid-gcp-common-26.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-module-guice-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/aether-util-0.9.0.M2.jar:/data/apache-druid-26.0.0/bin/../lib/opencsv-4.6.jar:/data/apache-druid-26.0.0/bin/../lib/stax-ex-1.8.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-datatype-guava-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/guice-servlet-4.1.0.jar:/data/apache-druid-26.0.0/bin/../lib/log4j-core-2.18.0.jar:/data/apache-druid-26.0.0/bin/../lib/j2objc-annotations-1.1.jar:/data/apache-druid-26.0.0/bin/../lib/commons-collections-3.2.2.jar:/data/apache-druid-26.0.0/bin/../lib/json-smart-2.3.jar:/data/apache-druid-26.0.0/bin/../lib/guice-multibindings-4.1.0.jar:/data/apache-druid-26.0.0/bin/../lib/error_prone_annotations-2.11.0.jar:/data/apache-druid-26.0.0/bin/../lib/cron-scheduler-0.1.jar:/data/apache-druid-26.0.0/bin/../lib/derby-10.14.2.0.jar:/data/apache-druid-26.0.0/bin/../lib/netty-reactive-streams-2.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/druid-server-26.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/derbyclient-10.14.2.0.jar:/data/apache-druid-26.0.0/bin/../lib/asm-9.3.jar:/data/apache-druid-26.0.0/bin/../lib/druid-aws-common-26.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/rhino-1.7.11.jar:/data/apache-druid-26.0.0/bin/../lib/disruptor-3.3.6.jar:/data/apache-druid-26.0.0/bin/../lib/xz-1.8.jar:/data/apache-druid-26.0.0/bin/../lib/FastInfoset-1.2.15.jar:/data/apache-druid-26.0.0/bin/../lib/asm-analysis-9.3.jar:/data/apache-druid-26.0.0/bin/../lib/zstd-jni-1.5.2-3.jar:/data/apache-druid-26.0.0/bin/../lib/async-http-client-netty-utils-2.5.3.jar:/data/apache-druid-26.0.0/bin/../lib/netty-3.10.6.Final.jar:/data/apache-druid-26.0.0/bin/../lib/plexus-interpolation-1.19.jar:/data/apache-druid-26.0.0/bin/../lib/javax.el-api-3.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-servlets-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-datatype-joda-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/fastutil-extra-8.5.4.jar:/data/apache-druid-26.0.0/bin/../lib/caffeine-2.8.0.jar:/data/apache-druid-26.0.0/bin/../lib/audience-annotations-0.5.0.jar:/data/apache-druid-26.0.0/bin/../lib/commons-lang3-3.12.0.jar:/data/apache-druid-26.0.0/bin/../lib/jersey-servlet-1.19.4.jar:/data/apache-druid-26.0.0/bin/../lib/sigar-1.6.5.132.jar:/data/apache-druid-26.0.0/bin/../lib/maven-repository-metadata-3.1.1.jar:/data/apache-druid-26.0.0/bin/../lib/jakarta.inject-api-1.0.3.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-util-ajax-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-dataformat-cbor-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/aws-java-sdk-core-1.12.317.jar:/data/apache-druid-26.0.0/bin/../lib/aether-connector-file-0.9.0.M2.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-proxy-9.4.48.v20220622.jar
2023-10-05T09:29:41,736 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:java.library.path=/usr/java/packages/lib:/usr/lib/x86_64-linux-gnu/jni:/lib/x86_64-linux-gnu:/usr/lib/x86_64-linux-gnu:/usr/lib/jni:/lib:/usr/lib
2023-10-05T09:29:41,737 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:java.io.tmpdir=var/tmp
2023-10-05T09:29:41,737 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:java.compiler=<NA>
2023-10-05T09:29:41,737 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:os.name=Linux
2023-10-05T09:29:41,737 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:os.arch=amd64
2023-10-05T09:29:41,738 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:os.version=5.10.0-22-amd64
2023-10-05T09:29:41,738 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:user.name=root
2023-10-05T09:29:41,738 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:user.home=/root
2023-10-05T09:29:41,740 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:user.dir=/data/apache-druid-26.0.0
2023-10-05T09:29:41,740 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:os.memory.free=889MB
2023-10-05T09:29:41,741 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:os.memory.max=989MB
2023-10-05T09:29:41,741 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:os.memory.total=989MB
2023-10-05T09:29:41,750 INFO [main] org.apache.zookeeper.ZooKeeper - Initiating client connection, connectString=10.10.30.110:2181 sessionTimeout=30000 watcher=org.apache.curator.ConnectionState@2728add3
2023-10-05T09:29:41,759 INFO [main] org.apache.zookeeper.common.X509Util - Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation
2023-10-05T09:29:41,763 INFO [main] org.apache.zookeeper.ClientCnxnSocket - jute.maxbuffer value is 4194304 Bytes
2023-10-05T09:29:41,774 INFO [main] org.apache.zookeeper.ClientCnxn - zookeeper.request.timeout value is 0. feature enabled=
2023-10-05T09:29:41,805 INFO [main] org.apache.curator.framework.imps.CuratorFrameworkImpl - Default schema
2023-10-05T09:29:41,817 INFO [main-SendThread(10.10.30.110:2181)] org.apache.zookeeper.ClientCnxn - Opening socket connection to server druid-master.allip.local/10.10.30.110:2181. Will not attempt to authenticate using SASL (unknown error)
2023-10-05T09:29:41,837 INFO [main-SendThread(10.10.30.110:2181)] org.apache.zookeeper.ClientCnxn - Socket connection established, initiating session, client: /10.10.30.113:41452, server: druid-master.allip.local/10.10.30.110:2181
2023-10-05T09:29:41,855 INFO [main-SendThread(10.10.30.110:2181)] org.apache.zookeeper.ClientCnxn - Session establishment complete on server druid-master.allip.local/10.10.30.110:2181, sessionid = 0x1004751ff9500cf, negotiated timeout = 30000
2023-10-05T09:29:41,877 INFO [main-EventThread] org.apache.curator.framework.state.ConnectionStateManager - State change: CONNECTED
2023-10-05T09:29:41,898 INFO [main-EventThread] org.apache.curator.framework.imps.EnsembleTracker - New config event received: {}
2023-10-05T09:29:41,898 INFO [main-EventThread] org.apache.curator.framework.imps.EnsembleTracker - New config event received: {}
2023-10-05T09:29:41,929 WARN [NodeRoleWatcher[OVERLORD]] org.apache.druid.curator.discovery.CuratorDruidNodeDiscoveryProvider$NodeRoleWatcher - Ignored event type [CONNECTION_RECONNECTED] for node watcher of role [overlord].
2023-10-05T09:29:41,930 WARN [NodeRoleWatcher[COORDINATOR]] org.apache.druid.curator.discovery.CuratorDruidNodeDiscoveryProvider$NodeRoleWatcher - Ignored event type [CONNECTION_RECONNECTED] for node watcher of role [coordinator].
2023-10-05T09:29:41,952 INFO [NodeRoleWatcher[COORDINATOR]] org.apache.druid.discovery.BaseNodeRoleWatcher - Node [http://10.10.30.110:8081] of role [coordinator] detected.
2023-10-05T09:29:41,953 INFO [NodeRoleWatcher[COORDINATOR]] org.apache.druid.discovery.BaseNodeRoleWatcher - Node watcher of role [coordinator] is now initialized with 1 nodes.
2023-10-05T09:29:41,955 INFO [NodeRoleWatcher[OVERLORD]] org.apache.druid.discovery.BaseNodeRoleWatcher - Node [http://10.10.30.110:8081] of role [overlord] detected.
2023-10-05T09:29:41,955 INFO [NodeRoleWatcher[OVERLORD]] org.apache.druid.discovery.BaseNodeRoleWatcher - Node watcher of role [overlord] is now initialized with 1 nodes.
2023-10-05T09:29:42,028 INFO [main] org.apache.druid.indexing.worker.executor.ExecutorLifecycle - Running with task: {
"type" : "index_kafka",
"id" : "index_kafka_sms-test-data_6656156d2ee944a_hdllhbmo",
"resource" : {
"availabilityGroup" : "index_kafka_sms-test-data_6656156d2ee944a",
"requiredCapacity" : 1
},
"dataSchema" : {
"dataSource" : "sms-test-data",
"timestampSpec" : {
"column" : "DateTime",
"format" : "auto",
"missingValue" : null
},
"dimensionsSpec" : {
"dimensions" : [ {
"type" : "string",
"name" : "InEndpointId",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : true
}, {
"type" : "string",
"name" : "InEndpointRoutingId",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : true
}, {
"type" : "string",
"name" : "InStatus",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : true
}, {
"type" : "string",
"name" : "OutDestination",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : true
}, {
"type" : "string",
"name" : "SubrouteId",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : true
}, {
"type" : "long",
"name" : "OutSeizures",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : false
}, {
"type" : "long",
"name" : "InDlrSeizures",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : false
}, {
"type" : "string",
"name" : "OutStatus",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : true
}, {
"type" : "long",
"name" : "OutDlrSuccess",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : false
}, {
"type" : "long",
"name" : "OutDlrTime",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : false
}, {
"type" : "string",
"name" : "OutEndpointRoutingId",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : true
}, {
"type" : "string",
"name" : "OutEndpointId",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : true
}, {
"type" : "long",
"name" : "InUnits",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : false
}, {
"type" : "string",
"name" : "InDlrStatus",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : true
}, {
"type" : "string",
"name" : "InOrigination",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : true
}, {
"type" : "long",
"name" : "InDlrSuccess",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : false
}, {
"type" : "string",
"name" : "InFinalDlrTimestamp",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : true
}, {
"type" : "string",
"name" : "InDestination",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : true
}, {
"type" : "long",
"name" : "OutUnits",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : false
}, {
"type" : "string",
"name" : "OutDlrStatus",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : true
}, {
"type" : "long",
"name" : "InDlrReceived",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : false
}, {
"type" : "string",
"name" : "RouteId",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : true
}, {
"type" : "long",
"name" : "OutDlrReceived",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : false
}, {
"type" : "string",
"name" : "MlResult",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : true
}, {
"type" : "long",
"name" : "OutDlrSeizures",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : false
}, {
"type" : "long",
"name" : "InDlrTime",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : false
}, {
"type" : "string",
"name" : "OutOrigination",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : true
}, {
"type" : "string",
"name" : "OutFinalDlrTimestamp",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : true
}, {
"type" : "long",
"name" : "InSeizures",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : false
}, {
"type" : "string",
"name" : "TrafficLabel",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : true
} ],
"dimensionExclusions" : [ "__time", "DateTime" ],
"includeAllDimensions" : false,
"useSchemaDiscovery" : false
},
"metricsSpec" : [ ],
"granularitySpec" : {
"type" : "uniform",
"segmentGranularity" : "HOUR",
"queryGranularity" : {
"type" : "none"
},
"rollup" : false,
"intervals" : [ ]
},
"transformSpec" : {
"filter" : null,
"transforms" : [ ]
}
},
"tuningConfig" : {
"type" : "KafkaTuningConfig",
"appendableIndexSpec" : {
"type" : "onheap",
"preserveExistingMetrics" : false
},
"maxRowsInMemory" : 150000,
"maxBytesInMemory" : 0,
"skipBytesInMemoryOverheadCheck" : false,
"maxRowsPerSegment" : 5000000,
"maxTotalRows" : null,
"intermediatePersistPeriod" : "PT10M",
"maxPendingPersists" : 0,
"indexSpec" : {
"bitmap" : {
"type" : "roaring"
},
"dimensionCompression" : "lz4",
"stringDictionaryEncoding" : {
"type" : "utf8"
},
"metricCompression" : "lz4",
"longEncoding" : "longs"
},
"indexSpecForIntermediatePersists" : {
"bitmap" : {
"type" : "roaring"
},
"dimensionCompression" : "lz4",
"stringDictionaryEncoding" : {
"type" : "utf8"
},
"metricCompression" : "lz4",
"longEncoding" : "longs"
},
"reportParseExceptions" : false,
"handoffConditionTimeout" : 0,
"resetOffsetAutomatically" : false,
"segmentWriteOutMediumFactory" : null,
"intermediateHandoffPeriod" : "P2147483647D",
"logParseExceptions" : false,
"maxParseExceptions" : 2147483647,
"maxSavedParseExceptions" : 0,
"skipSequenceNumberAvailabilityCheck" : false
},
"ioConfig" : {
"type" : "kafka",
"taskGroupId" : 0,
"baseSequenceName" : "index_kafka_sms-test-data_6656156d2ee944a",
"startPartitions" : {
"type" : "end",
"stream" : "sms-test-events",
"topic" : "sms-test-events",
"partitionSequenceNumberMap" : {
"0" : 6981,
"1" : 7343,
"2" : 7229,
"3" : 7089,
"4" : 6894
},
"partitionOffsetMap" : {
"0" : 6981,
"1" : 7343,
"2" : 7229,
"3" : 7089,
"4" : 6894
}
},
"endPartitions" : {
"type" : "end",
"stream" : "sms-test-events",
"topic" : "sms-test-events",
"partitionSequenceNumberMap" : {
"0" : 9223372036854775807,
"1" : 9223372036854775807,
"2" : 9223372036854775807,
"3" : 9223372036854775807,
"4" : 9223372036854775807
},
"partitionOffsetMap" : {
"0" : 9223372036854775807,
"1" : 9223372036854775807,
"2" : 9223372036854775807,
"3" : 9223372036854775807,
"4" : 9223372036854775807
}
},
"startSequenceNumbers" : {
"type" : "start",
"stream" : "sms-test-events",
"topic" : "sms-test-events",
"partitionSequenceNumberMap" : {
"0" : 6981,
"1" : 7343,
"2" : 7229,
"3" : 7089,
"4" : 6894
},
"partitionOffsetMap" : {
"0" : 6981,
"1" : 7343,
"2" : 7229,
"3" : 7089,
"4" : 6894
},
"exclusivePartitions" : [ ]
},
"endSequenceNumbers" : {
"type" : "end",
"stream" : "sms-test-events",
"topic" : "sms-test-events",
"partitionSequenceNumberMap" : {
"0" : 9223372036854775807,
"1" : 9223372036854775807,
"2" : 9223372036854775807,
"3" : 9223372036854775807,
"4" : 9223372036854775807
},
"partitionOffsetMap" : {
"0" : 9223372036854775807,
"1" : 9223372036854775807,
"2" : 9223372036854775807,
"3" : 9223372036854775807,
"4" : 9223372036854775807
}
},
"consumerProperties" : {
"bootstrap.servers" : "10.10.30.110:9092,10.10.30.111:9092,10.10.30.112:9092,10.10.30.113:9092"
},
"pollTimeout" : 100,
"useTransaction" : true,
"inputFormat" : {
"type" : "kafka",
"headerFormat" : null,
"keyFormat" : null,
"valueFormat" : {
"type" : "json",
"keepNullColumns" : false,
"assumeNewlineDelimited" : false,
"useJsonNodeReader" : false
},
"headerColumnPrefix" : "kafka.header.",
"keyColumnName" : "kafka.key",
"timestampColumnName" : "kafka.timestamp"
},
"configOverrides" : null
},
"context" : {
"checkpoints" : "{\"0\":{\"0\":6981,\"1\":7343,\"2\":7229,\"3\":7089,\"4\":6894}}",
"useLineageBasedSegmentAllocation" : true,
"IS_INCREMENTAL_HANDOFF_SUPPORTED" : true,
"forceTimeChunkLock" : true
},
"groupId" : "index_kafka_sms-test-data",
"dataSource" : "sms-test-data"
}
2023-10-05T09:29:42,034 INFO [main] org.apache.druid.indexing.worker.executor.ExecutorLifecycle - Attempting to lock file[/data/druid/task/index_kafka_sms-test-data_6656156d2ee944a_hdllhbmo/lock].
2023-10-05T09:29:42,035 INFO [main] org.apache.druid.indexing.worker.executor.ExecutorLifecycle - Acquired lock file[/data/druid/task/index_kafka_sms-test-data_6656156d2ee944a_hdllhbmo/lock] in 1ms.
2023-10-05T09:29:42,039 INFO [main] org.apache.druid.segment.loading.SegmentLocalCacheManager - Using storage location strategy: [LeastBytesUsedStorageLocationSelectorStrategy]
2023-10-05T09:29:42,049 INFO [main] org.apache.druid.server.coordination.SegmentLoadDropHandler - Starting...
2023-10-05T09:29:42,049 INFO [main] org.apache.druid.server.coordination.CuratorDataSegmentServerAnnouncer - Announcing self[DruidServerMetadata{name='10.10.30.113:8100', hostAndPort='10.10.30.113:8100', hostAndTlsPort='null', maxSize=0, tier='_default_tier', type=indexer-executor, priority=0}] at [/data/zk/announcements/10.10.30.113:8100]
2023-10-05T09:29:42,051 INFO [task-runner-0-priority-0] org.apache.druid.indexing.overlord.SingleTaskBackgroundRunner - Running task: index_kafka_sms-test-data_6656156d2ee944a_hdllhbmo
2023-10-05T09:29:42,056 INFO [main] org.apache.druid.server.coordination.SegmentLoadDropHandler - Started.
2023-10-05T09:29:42,059 INFO [main] org.apache.druid.server.coordination.ZkCoordinator - Starting zkCoordinator for server[10.10.30.113:8100]
2023-10-05T09:29:42,088 INFO [main] org.apache.druid.java.util.common.lifecycle.Lifecycle - Starting lifecycle [module] stage [SERVER]
2023-10-05T09:29:42,091 INFO [main] org.eclipse.jetty.server.Server - jetty-9.4.48.v20220622; built: 2022-06-21T20:42:25.880Z; git: 6b67c5719d1f4371b33655ff2d047d24e171e49a; jvm 11.0.18+10-post-Debian-1deb11u1
2023-10-05T09:29:42,172 INFO [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Starting with sequences: [SequenceMetadata{sequenceId=0, sequenceName='index_kafka_sms-test-data_6656156d2ee944a_0', assignments=[0, 1, 2, 3, 4], startOffsets={0=6981, 1=7343, 2=7229, 3=7089, 4=6894}, exclusiveStartPartitions=[], endOffsets={0=9223372036854775807, 1=9223372036854775807, 2=9223372036854775807, 3=9223372036854775807, 4=9223372036854775807}, sentinel=false, checkpointed=false}]
2023-10-05T09:29:42,200 INFO [main] org.eclipse.jetty.server.session - DefaultSessionIdManager workerName=node0
2023-10-05T09:29:42,200 INFO [main] org.eclipse.jetty.server.session - No SessionScavenger set, using defaults
2023-10-05T09:29:42,202 INFO [main] org.eclipse.jetty.server.session - node0 Scavenging every 600000ms
2023-10-05T09:29:42,311 INFO [main] com.sun.jersey.server.impl.application.WebApplicationImpl - Initiating Jersey application, version 'Jersey: 1.19.4 05/24/2017 03:20 PM'
2023-10-05T09:29:42,319 INFO [task-runner-0-priority-0] org.apache.kafka.clients.consumer.ConsumerConfig - ConsumerConfig values:
allow.auto.create.topics = true
auto.commit.interval.ms = 5000
auto.include.jmx.reporter = true
auto.offset.reset = none
bootstrap.servers = [10.10.30.110:9092, 10.10.30.111:9092, 10.10.30.112:9092, 10.10.30.113:9092]
check.crcs = true
client.dns.lookup = use_all_dns_ips
client.id = consumer-kafka-supervisor-cmlbailo-1
client.rack =
connections.max.idle.ms = 540000
default.api.timeout.ms = 60000
enable.auto.commit = false
exclude.internal.topics = true
fetch.max.bytes = 52428800
fetch.max.wait.ms = 500
fetch.min.bytes = 1
group.id = kafka-supervisor-cmlbailo
group.instance.id = null
heartbeat.interval.ms = 3000
interceptor.classes = []
internal.leave.group.on.close = true
internal.throw.on.fetch.stable.offset.unsupported = false
isolation.level = read_committed
key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
max.partition.fetch.bytes = 1048576
max.poll.interval.ms = 300000
max.poll.records = 500
metadata.max.age.ms = 10000
metric.reporters = []
metrics.num.samples = 2
metrics.recording.level = INFO
metrics.sample.window.ms = 30000
partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor]
receive.buffer.bytes = 65536
reconnect.backoff.max.ms = 1000
reconnect.backoff.ms = 50
request.timeout.ms = 30000
retry.backoff.ms = 100
sasl.client.callback.handler.class = null
sasl.jaas.config = null
sasl.kerberos.kinit.cmd = /usr/bin/kinit
sasl.kerberos.min.time.before.relogin = 60000
sasl.kerberos.service.name = null
sasl.kerberos.ticket.renew.jitter = 0.05
sasl.kerberos.ticket.renew.window.factor = 0.8
sasl.login.callback.handler.class = null
sasl.login.class = null
sasl.login.connect.timeout.ms = null
sasl.login.read.timeout.ms = null
sasl.login.refresh.buffer.seconds = 300
sasl.login.refresh.min.period.seconds = 60
sasl.login.refresh.window.factor = 0.8
sasl.login.refresh.window.jitter = 0.05
sasl.login.retry.backoff.max.ms = 10000
sasl.login.retry.backoff.ms = 100
sasl.mechanism = GSSAPI
sasl.oauthbearer.clock.skew.seconds = 30
sasl.oauthbearer.expected.audience = null
sasl.oauthbearer.expected.issuer = null
sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
sasl.oauthbearer.jwks.endpoint.url = null
sasl.oauthbearer.scope.claim.name = scope
sasl.oauthbearer.sub.claim.name = sub
sasl.oauthbearer.token.endpoint.url = null
security.protocol = PLAINTEXT
security.providers = null
send.buffer.bytes = 131072
session.timeout.ms = 45000
socket.connection.setup.timeout.max.ms = 30000
socket.connection.setup.timeout.ms = 10000
ssl.cipher.suites = null
ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
ssl.endpoint.identification.algorithm = https
ssl.engine.factory.class = null
ssl.key.password = null
ssl.keymanager.algorithm = SunX509
ssl.keystore.certificate.chain = null
ssl.keystore.key = null
ssl.keystore.location = null
ssl.keystore.password = null
ssl.keystore.type = JKS
ssl.protocol = TLSv1.3
ssl.provider = null
ssl.secure.random.implementation = null
ssl.trustmanager.algorithm = PKIX
ssl.truststore.certificates = null
ssl.truststore.location = null
ssl.truststore.password = null
ssl.truststore.type = JKS
value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
2023-10-05T09:29:42,776 INFO [task-runner-0-priority-0] org.apache.kafka.common.utils.AppInfoParser - Kafka version: 3.4.0
2023-10-05T09:29:42,776 INFO [task-runner-0-priority-0] org.apache.kafka.common.utils.AppInfoParser - Kafka commitId: 2e1947d240607d53
2023-10-05T09:29:42,776 INFO [task-runner-0-priority-0] org.apache.kafka.common.utils.AppInfoParser - Kafka startTimeMs: 1696498182773
2023-10-05T09:29:42,784 INFO [task-runner-0-priority-0] org.apache.druid.curator.discovery.CuratorDruidNodeAnnouncer - Announced self [{"druidNode":{"service":"druid/middleManager","host":"10.10.30.113","bindOnHost":false,"plaintextPort":8100,"port":-1,"tlsPort":-1,"enablePlaintextPort":true,"enableTlsPort":false},"nodeType":"peon","services":{"dataNodeService":{"type":"dataNodeService","tier":"_default_tier","maxSize":0,"type":"indexer-executor","serverType":"indexer-executor","priority":0},"lookupNodeService":{"type":"lookupNodeService","lookupTier":"__default"}}}].
2023-10-05T09:29:42,866 INFO [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Initialized sequences: SequenceMetadata{sequenceId=0, sequenceName='index_kafka_sms-test-data_6656156d2ee944a_0', assignments=[0, 1, 2, 3, 4], startOffsets={0=6981, 1=7343, 2=7229, 3=7089, 4=6894}, exclusiveStartPartitions=[], endOffsets={0=9223372036854775807, 1=9223372036854775807, 2=9223372036854775807, 3=9223372036854775807, 4=9223372036854775807}, sentinel=false, checkpointed=false}
2023-10-05T09:29:42,873 INFO [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Adding partition[0], start[6981] -> end[9223372036854775807] to assignment.
2023-10-05T09:29:42,873 INFO [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Adding partition[1], start[7343] -> end[9223372036854775807] to assignment.
2023-10-05T09:29:42,874 INFO [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Adding partition[2], start[7229] -> end[9223372036854775807] to assignment.
2023-10-05T09:29:42,874 INFO [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Adding partition[3], start[7089] -> end[9223372036854775807] to assignment.
2023-10-05T09:29:42,874 INFO [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Adding partition[4], start[6894] -> end[9223372036854775807] to assignment.
2023-10-05T09:29:42,876 INFO [task-runner-0-priority-0] org.apache.kafka.clients.consumer.KafkaConsumer - [Consumer clientId=consumer-kafka-supervisor-cmlbailo-1, groupId=kafka-supervisor-cmlbailo] Assigned to partition(s): sms-test-events-1, sms-test-events-0, sms-test-events-3, sms-test-events-2, sms-test-events-4
2023-10-05T09:29:42,883 INFO [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Seeking partition[4] to[6894].
2023-10-05T09:29:42,888 INFO [task-runner-0-priority-0] org.apache.kafka.clients.consumer.KafkaConsumer - [Consumer clientId=consumer-kafka-supervisor-cmlbailo-1, groupId=kafka-supervisor-cmlbailo] Seeking to offset 6894 for partition sms-test-events-4
2023-10-05T09:29:42,892 INFO [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Seeking partition[3] to[7089].
2023-10-05T09:29:42,892 INFO [task-runner-0-priority-0] org.apache.kafka.clients.consumer.KafkaConsumer - [Consumer clientId=consumer-kafka-supervisor-cmlbailo-1, groupId=kafka-supervisor-cmlbailo] Seeking to offset 7089 for partition sms-test-events-3
2023-10-05T09:29:42,892 INFO [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Seeking partition[2] to[7229].
2023-10-05T09:29:42,892 INFO [task-runner-0-priority-0] org.apache.kafka.clients.consumer.KafkaConsumer - [Consumer clientId=consumer-kafka-supervisor-cmlbailo-1, groupId=kafka-supervisor-cmlbailo] Seeking to offset 7229 for partition sms-test-events-2
2023-10-05T09:29:42,892 INFO [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Seeking partition[1] to[7343].
2023-10-05T09:29:42,893 INFO [task-runner-0-priority-0] org.apache.kafka.clients.consumer.KafkaConsumer - [Consumer clientId=consumer-kafka-supervisor-cmlbailo-1, groupId=kafka-supervisor-cmlbailo] Seeking to offset 7343 for partition sms-test-events-1
2023-10-05T09:29:42,893 INFO [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Seeking partition[0] to[6981].
2023-10-05T09:29:42,893 INFO [task-runner-0-priority-0] org.apache.kafka.clients.consumer.KafkaConsumer - [Consumer clientId=consumer-kafka-supervisor-cmlbailo-1, groupId=kafka-supervisor-cmlbailo] Seeking to offset 6981 for partition sms-test-events-0
2023-10-05T09:29:43,262 INFO [main] org.eclipse.jetty.server.handler.ContextHandler - Started o.e.j.s.ServletContextHandler@43cf97a8{/,null,AVAILABLE}
2023-10-05T09:29:43,284 INFO [main] org.eclipse.jetty.server.AbstractConnector - Started ServerConnector@7674f9d4{HTTP/1.1, (http/1.1)}{0.0.0.0:8100}
2023-10-05T09:29:43,288 INFO [main] org.eclipse.jetty.server.Server - Started @9523ms
2023-10-05T09:29:43,288 INFO [main] org.apache.druid.java.util.common.lifecycle.Lifecycle - Starting lifecycle [module] stage [ANNOUNCEMENTS]
2023-10-05T09:29:43,323 INFO [main] org.apache.druid.java.util.common.lifecycle.Lifecycle - Successfully started lifecycle [module]
2023-10-05T09:29:43,766 INFO [task-runner-0-priority-0] org.apache.kafka.clients.Metadata - [Consumer clientId=consumer-kafka-supervisor-cmlbailo-1, groupId=kafka-supervisor-cmlbailo] Resetting the last seen epoch of partition sms-test-events-0 to 51 since the associated topicId changed from null to 7NrOpCaDSwaBErHbCkoPQw
2023-10-05T09:29:43,767 INFO [task-runner-0-priority-0] org.apache.kafka.clients.Metadata - [Consumer clientId=consumer-kafka-supervisor-cmlbailo-1, groupId=kafka-supervisor-cmlbailo] Resetting the last seen epoch of partition sms-test-events-4 to 52 since the associated topicId changed from null to 7NrOpCaDSwaBErHbCkoPQw
2023-10-05T09:29:43,767 INFO [task-runner-0-priority-0] org.apache.kafka.clients.Metadata - [Consumer clientId=consumer-kafka-supervisor-cmlbailo-1, groupId=kafka-supervisor-cmlbailo] Resetting the last seen epoch of partition sms-test-events-1 to 58 since the associated topicId changed from null to 7NrOpCaDSwaBErHbCkoPQw
2023-10-05T09:29:43,767 INFO [task-runner-0-priority-0] org.apache.kafka.clients.Metadata - [Consumer clientId=consumer-kafka-supervisor-cmlbailo-1, groupId=kafka-supervisor-cmlbailo] Resetting the last seen epoch of partition sms-test-events-2 to 52 since the associated topicId changed from null to 7NrOpCaDSwaBErHbCkoPQw
2023-10-05T09:29:43,767 INFO [task-runner-0-priority-0] org.apache.kafka.clients.Metadata - [Consumer clientId=consumer-kafka-supervisor-cmlbailo-1, groupId=kafka-supervisor-cmlbailo] Resetting the last seen epoch of partition sms-test-events-3 to 59 since the associated topicId changed from null to 7NrOpCaDSwaBErHbCkoPQw
2023-10-05T09:29:43,770 INFO [task-runner-0-priority-0] org.apache.kafka.clients.Metadata - [Consumer clientId=consumer-kafka-supervisor-cmlbailo-1, groupId=kafka-supervisor-cmlbailo] Cluster ID: GFheUdOUTIaJChazUuEzrQ
2023-10-05T09:29:44,332 INFO [task-runner-0-priority-0] org.apache.druid.server.coordination.BatchDataSegmentAnnouncer - Announcing segment[sms-test-data_2023-10-02T09:00:00.000Z_2023-10-02T10:00:00.000Z_2023-10-05T08:54:50.739Z] at new path[/data/zk/segments/10.10.30.113:8100/10.10.30.113:8100_indexer-executor__default_tier_2023-10-05T09:29:44.328Z_8baaa0b03d194084ab204f4cf85717c40]
2023-10-05T09:29:45,011 INFO [task-runner-0-priority-0] org.apache.druid.server.coordination.BatchDataSegmentAnnouncer - Announcing segment[sms-test-data_2023-10-02T10:00:00.000Z_2023-10-02T11:00:00.000Z_2023-10-05T08:54:51.412Z] at existing path[/data/zk/segments/10.10.30.113:8100/10.10.30.113:8100_indexer-executor__default_tier_2023-10-05T09:29:44.328Z_8baaa0b03d194084ab204f4cf85717c40]
2023-10-05T09:29:45,678 INFO [task-runner-0-priority-0] org.apache.druid.server.coordination.BatchDataSegmentAnnouncer - Announcing segment[sms-test-data_2023-10-02T12:00:00.000Z_2023-10-02T13:00:00.000Z_2023-10-05T08:54:52.000Z] at existing path[/data/zk/segments/10.10.30.113:8100/10.10.30.113:8100_indexer-executor__default_tier_2023-10-05T09:29:44.328Z_8baaa0b03d194084ab204f4cf85717c40]
2023-10-05T09:29:46,304 INFO [task-runner-0-priority-0] org.apache.druid.server.coordination.BatchDataSegmentAnnouncer - Announcing segment[sms-test-data_2023-10-02T14:00:00.000Z_2023-10-02T15:00:00.000Z_2023-10-05T08:54:52.632Z] at existing path[/data/zk/segments/10.10.30.113:8100/10.10.30.113:8100_indexer-executor__default_tier_2023-10-05T09:29:44.328Z_8baaa0b03d194084ab204f4cf85717c40]
2023-10-05T09:29:46,859 INFO [task-runner-0-priority-0] org.apache.druid.server.coordination.BatchDataSegmentAnnouncer - Announcing segment[sms-test-data_2023-10-02T15:00:00.000Z_2023-10-02T16:00:00.000Z_2023-10-05T08:54:53.220Z] at existing path[/data/zk/segments/10.10.30.113:8100/10.10.30.113:8100_indexer-executor__default_tier_2023-10-05T09:29:44.328Z_8baaa0b03d194084ab204f4cf85717c40]
2023-10-05T09:29:47,457 INFO [task-runner-0-priority-0] org.apache.druid.server.coordination.BatchDataSegmentAnnouncer - Announcing segment[sms-test-data_2023-10-03T13:00:00.000Z_2023-10-03T14:00:00.000Z_2023-10-05T08:54:53.799Z] at existing path[/data/zk/segments/10.10.30.113:8100/10.10.30.113:8100_indexer-executor__default_tier_2023-10-05T09:29:44.328Z_8baaa0b03d194084ab204f4cf85717c40]
2023-10-05T09:29:48,038 INFO [task-runner-0-priority-0] org.apache.druid.server.coordination.BatchDataSegmentAnnouncer - Announcing segment[sms-test-data_2023-10-04T10:00:00.000Z_2023-10-04T11:00:00.000Z_2023-10-05T08:54:54.444Z] at existing path[/data/zk/segments/10.10.30.113:8100/10.10.30.113:8100_indexer-executor__default_tier_2023-10-05T09:29:44.328Z_8baaa0b03d194084ab204f4cf85717c40]
2023-10-05T09:29:48,045 ERROR [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Encountered exception in run() before persisting.
java.lang.NullPointerException: null
at org.apache.druid.segment.realtime.appenderator.BaseAppenderatorDriver.getAppendableSegment(BaseAppenderatorDriver.java:294) ~[druid-server-26.0.0.jar:26.0.0]
at org.apache.druid.segment.realtime.appenderator.BaseAppenderatorDriver.getSegment(BaseAppenderatorDriver.java:332) ~[druid-server-26.0.0.jar:26.0.0]
at org.apache.druid.segment.realtime.appenderator.BaseAppenderatorDriver.append(BaseAppenderatorDriver.java:407) ~[druid-server-26.0.0.jar:26.0.0]
at org.apache.druid.segment.realtime.appenderator.StreamAppenderatorDriver.add(StreamAppenderatorDriver.java:191) ~[druid-server-26.0.0.jar:26.0.0]
at org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner.runInternal(SeekableStreamIndexTaskRunner.java:654) ~[druid-indexing-service-26.0.0.jar:26.0.0]
at org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner.run(SeekableStreamIndexTaskRunner.java:266) ~[druid-indexing-service-26.0.0.jar:26.0.0]
at org.apache.druid.indexing.seekablestream.SeekableStreamIndexTask.runTask(SeekableStreamIndexTask.java:151) ~[druid-indexing-service-26.0.0.jar:26.0.0]
at org.apache.druid.indexing.common.task.AbstractTask.run(AbstractTask.java:173) ~[druid-indexing-service-26.0.0.jar:26.0.0]
at org.apache.druid.indexing.overlord.SingleTaskBackgroundRunner$SingleTaskBackgroundRunnerCallable.call(SingleTaskBackgroundRunner.java:477) ~[druid-indexing-service-26.0.0.jar:26.0.0]
at org.apache.druid.indexing.overlord.SingleTaskBackgroundRunner$SingleTaskBackgroundRunnerCallable.call(SingleTaskBackgroundRunner.java:449) ~[druid-indexing-service-26.0.0.jar:26.0.0]
at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~[?:?]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~[?:?]
at java.lang.Thread.run(Thread.java:829) ~[?:?]
2023-10-05T09:29:48,068 INFO [task-runner-0-priority-0] org.apache.druid.segment.realtime.appenderator.StreamAppenderator - Persisted rows[117] and (estimated) bytes[86,522]
2023-10-05T09:29:48,385 INFO [[index_kafka_sms-test-data_6656156d2ee944a_hdllhbmo]-appenderator-persist] org.apache.druid.segment.realtime.appenderator.StreamAppenderator - Flushed in-memory data for segment[sms-test-data_2023-10-03T13:00:00.000Z_2023-10-03T14:00:00.000Z_2023-10-05T08:54:53.799Z] spill[0] to disk in [316] ms (34 rows).
2023-10-05T09:29:48,493 INFO [[index_kafka_sms-test-data_6656156d2ee944a_hdllhbmo]-appenderator-persist] org.apache.druid.segment.realtime.appenderator.StreamAppenderator - Flushed in-memory data for segment[sms-test-data_2023-10-02T15:00:00.000Z_2023-10-02T16:00:00.000Z_2023-10-05T08:54:53.220Z] spill[0] to disk in [58] ms (16 rows).
2023-10-05T09:29:48,583 INFO [[index_kafka_sms-test-data_6656156d2ee944a_hdllhbmo]-appenderator-persist] org.apache.druid.segment.realtime.appenderator.StreamAppenderator - Flushed in-memory data for segment[sms-test-data_2023-10-02T09:00:00.000Z_2023-10-02T10:00:00.000Z_2023-10-05T08:54:50.739Z] spill[0] to disk in [82] ms (3 rows).
2023-10-05T09:29:48,652 INFO [[index_kafka_sms-test-data_6656156d2ee944a_hdllhbmo]-appenderator-persist] org.apache.druid.segment.realtime.appenderator.StreamAppenderator - Flushed in-memory data for segment[sms-test-data_2023-10-02T10:00:00.000Z_2023-10-02T11:00:00.000Z_2023-10-05T08:54:51.412Z] spill[0] to disk in [54] ms (34 rows).
2023-10-05T09:29:48,703 INFO [[index_kafka_sms-test-data_6656156d2ee944a_hdllhbmo]-appenderator-persist] org.apache.druid.segment.realtime.appenderator.StreamAppenderator - Flushed in-memory data for segment[sms-test-data_2023-10-02T14:00:00.000Z_2023-10-02T15:00:00.000Z_2023-10-05T08:54:52.632Z] spill[0] to disk in [45] ms (1 rows).
2023-10-05T09:29:48,764 INFO [[index_kafka_sms-test-data_6656156d2ee944a_hdllhbmo]-appenderator-persist] org.apache.druid.segment.realtime.appenderator.StreamAppenderator - Flushed in-memory data for segment[sms-test-data_2023-10-04T10:00:00.000Z_2023-10-04T11:00:00.000Z_2023-10-05T08:54:54.444Z] spill[0] to disk in [55] ms (1 rows).
2023-10-05T09:29:48,829 INFO [[index_kafka_sms-test-data_6656156d2ee944a_hdllhbmo]-appenderator-persist] org.apache.druid.segment.realtime.appenderator.StreamAppenderator - Flushed in-memory data for segment[sms-test-data_2023-10-02T12:00:00.000Z_2023-10-02T13:00:00.000Z_2023-10-05T08:54:52.000Z] spill[0] to disk in [59] ms (28 rows).
2023-10-05T09:29:48,850 INFO [[index_kafka_sms-test-data_6656156d2ee944a_hdllhbmo]-appenderator-persist] org.apache.druid.segment.realtime.appenderator.StreamAppenderator - Flushed in-memory data with commit metadata [AppenderatorDriverMetadata{segments={index_kafka_sms-test-data_6656156d2ee944a_0=[SegmentWithState{segmentIdentifier=sms-test-data_2023-10-02T09:00:00.000Z_2023-10-02T10:00:00.000Z_2023-10-05T08:54:50.739Z, state=APPENDING}, SegmentWithState{segmentIdentifier=sms-test-data_2023-10-02T10:00:00.000Z_2023-10-02T11:00:00.000Z_2023-10-05T08:54:51.412Z, state=APPENDING}, SegmentWithState{segmentIdentifier=sms-test-data_2023-10-02T12:00:00.000Z_2023-10-02T13:00:00.000Z_2023-10-05T08:54:52.000Z, state=APPENDING}, SegmentWithState{segmentIdentifier=sms-test-data_2023-10-02T14:00:00.000Z_2023-10-02T15:00:00.000Z_2023-10-05T08:54:52.632Z, state=APPENDING}, SegmentWithState{segmentIdentifier=sms-test-data_2023-10-02T15:00:00.000Z_2023-10-02T16:00:00.000Z_2023-10-05T08:54:53.220Z, state=APPENDING}, SegmentWithState{segmentIdentifier=sms-test-data_2023-10-03T13:00:00.000Z_2023-10-03T14:00:00.000Z_2023-10-05T08:54:53.799Z, state=APPENDING}, SegmentWithState{segmentIdentifier=sms-test-data_2023-10-04T10:00:00.000Z_2023-10-04T11:00:00.000Z_2023-10-05T08:54:54.444Z, state=APPENDING}]}, lastSegmentIds={index_kafka_sms-test-data_6656156d2ee944a_0=sms-test-data_2023-10-04T10:00:00.000Z_2023-10-04T11:00:00.000Z_2023-10-05T08:54:54.444Z}, callerMetadata={nextPartitions=SeekableStreamEndSequenceNumbers{stream='sms-test-events', partitionSequenceNumberMap={0=6981, 1=7343, 2=7229, 3=7206, 4=6894}}}}] for segments: sms-test-data_2023-10-03T13:00:00.000Z_2023-10-03T14:00:00.000Z_2023-10-05T08:54:53.799Z, sms-test-data_2023-10-02T15:00:00.000Z_2023-10-02T16:00:00.000Z_2023-10-05T08:54:53.220Z, sms-test-data_2023-10-02T09:00:00.000Z_2023-10-02T10:00:00.000Z_2023-10-05T08:54:50.739Z, sms-test-data_2023-10-02T10:00:00.000Z_2023-10-02T11:00:00.000Z_2023-10-05T08:54:51.412Z, sms-test-data_2023-10-02T14:00:00.000Z_2023-10-02T15:00:00.000Z_2023-10-05T08:54:52.632Z, sms-test-data_2023-10-04T10:00:00.000Z_2023-10-04T11:00:00.000Z_2023-10-05T08:54:54.444Z, sms-test-data_2023-10-02T12:00:00.000Z_2023-10-02T13:00:00.000Z_2023-10-05T08:54:52.000Z
2023-10-05T09:29:48,851 INFO [[index_kafka_sms-test-data_6656156d2ee944a_hdllhbmo]-appenderator-persist] org.apache.druid.segment.realtime.appenderator.StreamAppenderator - Persisted stats: processed rows: [117], persisted rows[117], sinks: [7], total fireHydrants (across sinks): [7], persisted fireHydrants (across sinks): [7]
2023-10-05T09:29:48,852 INFO [task-runner-0-priority-0] org.apache.kafka.common.metrics.Metrics - Metrics scheduler closed
2023-10-05T09:29:48,858 INFO [task-runner-0-priority-0] org.apache.kafka.common.metrics.Metrics - Closing reporter org.apache.kafka.common.metrics.JmxReporter
2023-10-05T09:29:48,858 INFO [task-runner-0-priority-0] org.apache.kafka.common.metrics.Metrics - Metrics reporters closed
2023-10-05T09:29:48,868 INFO [task-runner-0-priority-0] org.apache.kafka.common.utils.AppInfoParser - App info kafka.consumer for consumer-kafka-supervisor-cmlbailo-1 unregistered
2023-10-05T09:29:48,883 INFO [task-runner-0-priority-0] org.apache.druid.server.coordination.BatchDataSegmentAnnouncer - Unannouncing segment[sms-test-data_2023-10-03T13:00:00.000Z_2023-10-03T14:00:00.000Z_2023-10-05T08:54:53.799Z] at path[/data/zk/segments/10.10.30.113:8100/10.10.30.113:8100_indexer-executor__default_tier_2023-10-05T09:29:44.328Z_8baaa0b03d194084ab204f4cf85717c40]
2023-10-05T09:29:48,900 INFO [task-runner-0-priority-0] org.apache.druid.server.coordination.BatchDataSegmentAnnouncer - Unannouncing segment[sms-test-data_2023-10-02T15:00:00.000Z_2023-10-02T16:00:00.000Z_2023-10-05T08:54:53.220Z] at path[/data/zk/segments/10.10.30.113:8100/10.10.30.113:8100_indexer-executor__default_tier_2023-10-05T09:29:44.328Z_8baaa0b03d194084ab204f4cf85717c40]
2023-10-05T09:29:48,915 INFO [task-runner-0-priority-0] org.apache.druid.server.coordination.BatchDataSegmentAnnouncer - Unannouncing segment[sms-test-data_2023-10-02T09:00:00.000Z_2023-10-02T10:00:00.000Z_2023-10-05T08:54:50.739Z] at path[/data/zk/segments/10.10.30.113:8100/10.10.30.113:8100_indexer-executor__default_tier_2023-10-05T09:29:44.328Z_8baaa0b03d194084ab204f4cf85717c40]
2023-10-05T09:29:48,926 INFO [task-runner-0-priority-0] org.apache.druid.server.coordination.BatchDataSegmentAnnouncer - Unannouncing segment[sms-test-data_2023-10-02T10:00:00.000Z_2023-10-02T11:00:00.000Z_2023-10-05T08:54:51.412Z] at path[/data/zk/segments/10.10.30.113:8100/10.10.30.113:8100_indexer-executor__default_tier_2023-10-05T09:29:44.328Z_8baaa0b03d194084ab204f4cf85717c40]
2023-10-05T09:29:48,937 INFO [task-runner-0-priority-0] org.apache.druid.server.coordination.BatchDataSegmentAnnouncer - Unannouncing segment[sms-test-data_2023-10-02T14:00:00.000Z_2023-10-02T15:00:00.000Z_2023-10-05T08:54:52.632Z] at path[/data/zk/segments/10.10.30.113:8100/10.10.30.113:8100_indexer-executor__default_tier_2023-10-05T09:29:44.328Z_8baaa0b03d194084ab204f4cf85717c40]
2023-10-05T09:29:48,950 INFO [task-runner-0-priority-0] org.apache.druid.server.coordination.BatchDataSegmentAnnouncer - Unannouncing segment[sms-test-data_2023-10-04T10:00:00.000Z_2023-10-04T11:00:00.000Z_2023-10-05T08:54:54.444Z] at path[/data/zk/segments/10.10.30.113:8100/10.10.30.113:8100_indexer-executor__default_tier_2023-10-05T09:29:44.328Z_8baaa0b03d194084ab204f4cf85717c40]
2023-10-05T09:29:48,958 INFO [task-runner-0-priority-0] org.apache.druid.server.coordination.BatchDataSegmentAnnouncer - Unannouncing segment[sms-test-data_2023-10-02T12:00:00.000Z_2023-10-02T13:00:00.000Z_2023-10-05T08:54:52.000Z] at path[/data/zk/segments/10.10.30.113:8100/10.10.30.113:8100_indexer-executor__default_tier_2023-10-05T09:29:44.328Z_8baaa0b03d194084ab204f4cf85717c40]
2023-10-05T09:29:48,958 INFO [task-runner-0-priority-0] org.apache.druid.curator.announcement.Announcer - Unannouncing [/data/zk/segments/10.10.30.113:8100/10.10.30.113:8100_indexer-executor__default_tier_2023-10-05T09:29:44.328Z_8baaa0b03d194084ab204f4cf85717c40]
2023-10-05T09:29:48,975 INFO [task-runner-0-priority-0] org.apache.druid.curator.announcement.Announcer - Unannouncing [/data/zk/internal-discovery/PEON/10.10.30.113:8100]
2023-10-05T09:29:48,978 INFO [task-runner-0-priority-0] org.apache.druid.curator.discovery.CuratorDruidNodeAnnouncer - Unannounced self [{"druidNode":{"service":"druid/middleManager","host":"10.10.30.113","bindOnHost":false,"plaintextPort":8100,"port":-1,"tlsPort":-1,"enablePlaintextPort":true,"enableTlsPort":false},"nodeType":"peon","services":{"dataNodeService":{"type":"dataNodeService","tier":"_default_tier","maxSize":0,"type":"indexer-executor","serverType":"indexer-executor","priority":0},"lookupNodeService":{"type":"lookupNodeService","lookupTier":"__default"}}}].
2023-10-05T09:29:48,979 INFO [task-runner-0-priority-0] org.apache.druid.curator.announcement.Announcer - Unannouncing [/data/zk/announcements/10.10.30.113:8100]
2023-10-05T09:29:48,983 ERROR [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Encountered exception while running task.
java.lang.NullPointerException: null
at org.apache.druid.segment.realtime.appenderator.BaseAppenderatorDriver.getAppendableSegment(BaseAppenderatorDriver.java:294) ~[druid-server-26.0.0.jar:26.0.0]
at org.apache.druid.segment.realtime.appenderator.BaseAppenderatorDriver.getSegment(BaseAppenderatorDriver.java:332) ~[druid-server-26.0.0.jar:26.0.0]
at org.apache.druid.segment.realtime.appenderator.BaseAppenderatorDriver.append(BaseAppenderatorDriver.java:407) ~[druid-server-26.0.0.jar:26.0.0]
at org.apache.druid.segment.realtime.appenderator.StreamAppenderatorDriver.add(StreamAppenderatorDriver.java:191) ~[druid-server-26.0.0.jar:26.0.0]
at org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner.runInternal(SeekableStreamIndexTaskRunner.java:654) ~[druid-indexing-service-26.0.0.jar:26.0.0]
at org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner.run(SeekableStreamIndexTaskRunner.java:266) ~[druid-indexing-service-26.0.0.jar:26.0.0]
at org.apache.druid.indexing.seekablestream.SeekableStreamIndexTask.runTask(SeekableStreamIndexTask.java:151) ~[druid-indexing-service-26.0.0.jar:26.0.0]
at org.apache.druid.indexing.common.task.AbstractTask.run(AbstractTask.java:173) ~[druid-indexing-service-26.0.0.jar:26.0.0]
at org.apache.druid.indexing.overlord.SingleTaskBackgroundRunner$SingleTaskBackgroundRunnerCallable.call(SingleTaskBackgroundRunner.java:477) ~[druid-indexing-service-26.0.0.jar:26.0.0]
at org.apache.druid.indexing.overlord.SingleTaskBackgroundRunner$SingleTaskBackgroundRunnerCallable.call(SingleTaskBackgroundRunner.java:449) ~[druid-indexing-service-26.0.0.jar:26.0.0]
at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~[?:?]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~[?:?]
at java.lang.Thread.run(Thread.java:829) ~[?:?]
2023-10-05T09:29:48,994 INFO [task-runner-0-priority-0] org.apache.druid.indexing.worker.executor.ExecutorLifecycle - Task completed with status: {
"id" : "index_kafka_sms-test-data_6656156d2ee944a_hdllhbmo",
"status" : "FAILED",
"duration" : 6940,
"errorMsg" : "java.lang.NullPointerException\n\tat org.apache.druid.segment.realtime.appenderator.BaseAppenderatorDr...",
"location" : {
"host" : null,
"port" : -1,
"tlsPort" : -1
}
}
2023-10-05T09:29:49,000 INFO [main] org.apache.druid.java.util.common.lifecycle.Lifecycle - Stopping lifecycle [module] stage [ANNOUNCEMENTS]
2023-10-05T09:29:49,020 INFO [main] org.apache.druid.java.util.common.lifecycle.Lifecycle - Stopping lifecycle [module] stage [SERVER]
2023-10-05T09:29:49,032 INFO [main] org.eclipse.jetty.server.AbstractConnector - Stopped ServerConnector@7674f9d4{HTTP/1.1, (http/1.1)}{0.0.0.0:8100}
2023-10-05T09:29:49,032 INFO [main] org.eclipse.jetty.server.session - node0 Stopped scavenging
2023-10-05T09:29:49,034 INFO [main] org.eclipse.jetty.server.handler.ContextHandler - Stopped o.e.j.s.ServletContextHandler@43cf97a8{/,null,STOPPED}
2023-10-05T09:29:49,046 INFO [main] org.apache.druid.java.util.common.lifecycle.Lifecycle - Stopping lifecycle [module] stage [NORMAL]
2023-10-05T09:29:49,046 INFO [main] org.apache.druid.server.coordination.ZkCoordinator - Stopping ZkCoordinator for [DruidServerMetadata{name='10.10.30.113:8100', hostAndPort='10.10.30.113:8100', hostAndTlsPort='null', maxSize=0, tier='_default_tier', type=indexer-executor, priority=0}]
2023-10-05T09:29:49,047 INFO [main] org.apache.druid.server.coordination.SegmentLoadDropHandler - Stopping...
2023-10-05T09:29:49,047 INFO [main] org.apache.druid.server.coordination.SegmentLoadDropHandler - Stopped.
2023-10-05T09:29:49,048 INFO [main] org.apache.druid.indexing.overlord.SingleTaskBackgroundRunner - Starting graceful shutdown of task[index_kafka_sms-test-data_6656156d2ee944a_hdllhbmo].
2023-10-05T09:29:49,048 INFO [main] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Stopping forcefully (status: [READING])
2023-10-05T09:29:49,066 INFO [LookupExtractorFactoryContainerProvider-MainThread] org.apache.druid.query.lookup.LookupReferencesManager - Lookup Management loop exited. Lookup notices are not handled anymore.
2023-10-05T09:29:49,071 INFO [Curator-Framework-0] org.apache.curator.framework.imps.CuratorFrameworkImpl - backgroundOperationsLoop exiting
2023-10-05T09:29:49,178 INFO [main] org.apache.zookeeper.ZooKeeper - Session: 0x1004751ff9500cf closed
2023-10-05T09:29:49,179 INFO [main-EventThread] org.apache.zookeeper.ClientCnxn - EventThread shut down for session: 0x1004751ff9500cf
2023-10-05T09:29:49,204 INFO [main] org.apache.druid.java.util.common.lifecycle.Lifecycle - Stopping lifecycle [module] stage [INIT]
Finished peon task
WARNING: An illegal reflective access operation has occurred
WARNING: Illegal reflective access by com.google.inject.internal.cglib.core.$ReflectUtils$1 (file:/data/apache-druid-26.0.0/lib/guice-4.1.0.jar) to method java.lang.ClassLoader.defineClass(java.lang.String,byte[],int,int,java.security.ProtectionDomain)
WARNING: Please consider reporting this to the maintainers of com.google.inject.internal.cglib.core.$ReflectUtils$1
WARNING: Use --illegal-access=warn to enable warnings of further illegal reflective access operations
WARNING: All illegal access operations will be denied in a future release
2023-10-05T09:29:35,615 INFO [main] org.hibernate.validator.internal.util.Version - HV000001: Hibernate Validator 5.2.5.Final
2023-10-05T09:29:36,455 INFO [main] org.apache.druid.guice.ExtensionsLoader - Loading extension [druid-hdfs-storage], jars: hadoop-mapreduce-client-app-2.8.5.jar, leveldbjni-all-1.8.jar, commons-net-3.6.jar, hadoop-mapreduce-client-shuffle-2.8.5.jar, druid-hdfs-storage-26.0.0.jar, ion-java-1.0.2.jar, hadoop-yarn-server-common-2.8.5.jar, aws-java-sdk-s3-1.12.317.jar, nimbus-jose-jwt-4.41.1.jar, api-util-1.0.3.jar, apacheds-kerberos-codec-2.0.0-M15.jar, commons-digester-1.8.jar, curator-framework-5.4.0.jar, htrace-core4-4.0.1-incubating.jar, hadoop-common-2.8.5.jar, api-asn1-api-1.0.0-M20.jar, hadoop-yarn-client-2.8.5.jar, hadoop-annotations-2.8.5.jar, hadoop-mapreduce-client-core-2.8.5.jar, jcip-annotations-1.0-1.jar, commons-logging-1.1.1.jar, jackson-core-asl-1.9.13.jar, httpcore-4.4.11.jar, jsp-api-2.1.jar, curator-recipes-5.4.0.jar, httpclient-4.5.13.jar, apacheds-i18n-2.0.0-M15.jar, accessors-smart-1.2.jar, hadoop-aws-2.8.5.jar, aws-java-sdk-kms-1.12.317.jar, jmespath-java-1.12.317.jar, commons-codec-1.13.jar, hadoop-mapreduce-client-common-2.8.5.jar, hadoop-auth-2.8.5.jar, joda-time-2.12.4.jar, hadoop-hdfs-client-2.8.5.jar, jetty-sslengine-6.1.26.jar, hadoop-client-2.8.5.jar, hadoop-mapreduce-client-jobclient-2.8.5.jar, hadoop-yarn-api-2.8.5.jar, commons-configuration-1.6.jar, commons-collections-3.2.2.jar, json-smart-2.3.jar, xmlenc-0.52.jar, asm-9.3.jar, jackson-mapper-asl-1.9.13.jar, gson-2.2.4.jar, jackson-dataformat-cbor-2.10.5.jar, aws-java-sdk-core-1.12.317.jar
2023-10-05T09:29:36,485 INFO [main] org.apache.druid.guice.ExtensionsLoader - Loading extension [druid-kafka-indexing-service], jars: lz4-java-1.8.0.jar, snappy-java-1.1.8.4.jar, kafka-clients-3.4.0.jar, druid-kafka-indexing-service-26.0.0.jar, zstd-jni-1.5.2-3.jar
2023-10-05T09:29:36,489 INFO [main] org.apache.druid.guice.ExtensionsLoader - Loading extension [druid-datasketches], jars: commons-math3-3.6.1.jar, druid-datasketches-26.0.0.jar
2023-10-05T09:29:36,491 INFO [main] org.apache.druid.guice.ExtensionsLoader - Loading extension [druid-multi-stage-query], jars: druid-multi-stage-query-26.0.0.jar
2023-10-05T09:29:36,493 INFO [main] org.apache.druid.guice.ExtensionsLoader - Loading extension [mysql-metadata-storage], jars: mysql-metadata-storage-26.0.0.jar, mariadb-java-client-2.7.9.jar
2023-10-05T09:29:36,821 INFO [main] org.apache.druid.guice.ExtensionsLoader - Loading extension [druid-hdfs-storage], jars: hadoop-mapreduce-client-app-2.8.5.jar, leveldbjni-all-1.8.jar, commons-net-3.6.jar, hadoop-mapreduce-client-shuffle-2.8.5.jar, druid-hdfs-storage-26.0.0.jar, ion-java-1.0.2.jar, hadoop-yarn-server-common-2.8.5.jar, aws-java-sdk-s3-1.12.317.jar, nimbus-jose-jwt-4.41.1.jar, api-util-1.0.3.jar, apacheds-kerberos-codec-2.0.0-M15.jar, commons-digester-1.8.jar, curator-framework-5.4.0.jar, htrace-core4-4.0.1-incubating.jar, hadoop-common-2.8.5.jar, api-asn1-api-1.0.0-M20.jar, hadoop-yarn-client-2.8.5.jar, hadoop-annotations-2.8.5.jar, hadoop-mapreduce-client-core-2.8.5.jar, jcip-annotations-1.0-1.jar, commons-logging-1.1.1.jar, jackson-core-asl-1.9.13.jar, httpcore-4.4.11.jar, jsp-api-2.1.jar, curator-recipes-5.4.0.jar, httpclient-4.5.13.jar, apacheds-i18n-2.0.0-M15.jar, accessors-smart-1.2.jar, hadoop-aws-2.8.5.jar, aws-java-sdk-kms-1.12.317.jar, jmespath-java-1.12.317.jar, commons-codec-1.13.jar, hadoop-mapreduce-client-common-2.8.5.jar, hadoop-auth-2.8.5.jar, joda-time-2.12.4.jar, hadoop-hdfs-client-2.8.5.jar, jetty-sslengine-6.1.26.jar, hadoop-client-2.8.5.jar, hadoop-mapreduce-client-jobclient-2.8.5.jar, hadoop-yarn-api-2.8.5.jar, commons-configuration-1.6.jar, commons-collections-3.2.2.jar, json-smart-2.3.jar, xmlenc-0.52.jar, asm-9.3.jar, jackson-mapper-asl-1.9.13.jar, gson-2.2.4.jar, jackson-dataformat-cbor-2.10.5.jar, aws-java-sdk-core-1.12.317.jar
2023-10-05T09:29:36,824 INFO [main] org.apache.druid.guice.ExtensionsLoader - Loading extension [druid-kafka-indexing-service], jars: lz4-java-1.8.0.jar, snappy-java-1.1.8.4.jar, kafka-clients-3.4.0.jar, druid-kafka-indexing-service-26.0.0.jar, zstd-jni-1.5.2-3.jar
2023-10-05T09:29:36,827 INFO [main] org.apache.druid.guice.ExtensionsLoader - Loading extension [druid-datasketches], jars: commons-math3-3.6.1.jar, druid-datasketches-26.0.0.jar
2023-10-05T09:29:36,837 INFO [main] org.apache.druid.guice.ExtensionsLoader - Loading extension [druid-multi-stage-query], jars: druid-multi-stage-query-26.0.0.jar
2023-10-05T09:29:36,854 INFO [main] org.apache.druid.guice.ExtensionsLoader - Loading extension [mysql-metadata-storage], jars: mysql-metadata-storage-26.0.0.jar, mariadb-java-client-2.7.9.jar
2023-10-05T09:29:38,177 WARN [main] org.apache.hadoop.util.NativeCodeLoader - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2023-10-05T09:29:39,704 INFO [main] org.apache.druid.guice.JsonConfigurator - Skipping druid.emitter.logging.logLevel property: one of it's prefixes is also used as a property key. Prefix: druid
2023-10-05T09:29:39,845 INFO [main] org.apache.druid.server.emitter.EmitterModule - Using emitter [NoopEmitter{}] for metrics and alerts, with dimensions [{version=26.0.0}].
2023-10-05T09:29:40,507 INFO [main] org.apache.druid.server.metrics.MetricsModule - Loaded 3 monitors: org.apache.druid.java.util.metrics.JvmMonitor, org.apache.druid.query.ExecutorServiceMonitor, org.apache.druid.server.initialization.jetty.JettyServerModule$JettyMonitor
2023-10-05T09:29:40,527 INFO [main] org.apache.druid.cli.CliPeon - Starting up with processors [1], memory [1,037,959,168], maxMemory [1,037,959,168], directMemory [1,073,741,824]. Properties follow.
2023-10-05T09:29:40,528 INFO [main] org.apache.druid.cli.CliPeon - * attemptId: 1
2023-10-05T09:29:40,528 INFO [main] org.apache.druid.cli.CliPeon - * awt.toolkit: sun.awt.X11.XToolkit
2023-10-05T09:29:40,528 INFO [main] org.apache.druid.cli.CliPeon - * druid.emitter: noop
2023-10-05T09:29:40,529 INFO [main] org.apache.druid.cli.CliPeon - * druid.emitter.logging.logLevel: info
2023-10-05T09:29:40,529 INFO [main] org.apache.druid.cli.CliPeon - * druid.expressions.useStrictBooleans: true
2023-10-05T09:29:40,529 INFO [main] org.apache.druid.cli.CliPeon - * druid.extensions.loadList: ["druid-hdfs-storage", "druid-kafka-indexing-service", "druid-datasketches", "druid-multi-stage-query", "mysql-metadata-storage"]
2023-10-05T09:29:40,530 INFO [main] org.apache.druid.cli.CliPeon - * druid.global.http.eagerInitialization: false
2023-10-05T09:29:40,531 INFO [main] org.apache.druid.cli.CliPeon - * druid.host: 10.10.30.113
2023-10-05T09:29:40,531 INFO [main] org.apache.druid.cli.CliPeon - * druid.indexer.fork.property.druid.processing.buffer.sizeBytes: 100MiB
2023-10-05T09:29:40,531 INFO [main] org.apache.druid.cli.CliPeon - * druid.indexer.fork.property.druid.processing.numMergeBuffers: 2
2023-10-05T09:29:40,532 INFO [main] org.apache.druid.cli.CliPeon - * druid.indexer.fork.property.druid.processing.numThreads: 1
2023-10-05T09:29:40,532 INFO [main] org.apache.druid.cli.CliPeon - * druid.indexer.logs.directory: /data/deep/indexing-logs
2023-10-05T09:29:40,532 INFO [main] org.apache.druid.cli.CliPeon - * druid.indexer.logs.type: file
2023-10-05T09:29:40,533 INFO [main] org.apache.druid.cli.CliPeon - * druid.indexer.runner.javaCommand: bin/run-java
2023-10-05T09:29:40,533 INFO [main] org.apache.druid.cli.CliPeon - * druid.indexer.runner.javaOptsArray: ["-server","-Xms1g","-Xmx1g","-XX:MaxDirectMemorySize=1g","-Duser.timezone=UTC","-Dfile.encoding=UTF-8","-XX:+ExitOnOutOfMemoryError","-Djava.util.logging.manager=org.apache.logging.log4j.jul.LogManager"]
2023-10-05T09:29:40,534 INFO [main] org.apache.druid.cli.CliPeon - * druid.indexer.task.baseTaskDir: /data/druid/task
2023-10-05T09:29:40,534 INFO [main] org.apache.druid.cli.CliPeon - * druid.indexer.task.hadoopWorkingPath: /data/druid/hadoop-tmp
2023-10-05T09:29:40,535 INFO [main] org.apache.druid.cli.CliPeon - * druid.indexing.doubleStorage: double
2023-10-05T09:29:40,536 INFO [main] org.apache.druid.cli.CliPeon - * druid.log.path: /data/apache-druid-26.0.0/bin/../log
2023-10-05T09:29:40,536 INFO [main] org.apache.druid.cli.CliPeon - * druid.lookup.enableLookupSyncOnStartup: false
2023-10-05T09:29:40,537 INFO [main] org.apache.druid.cli.CliPeon - * druid.metadata.mysql.driver.driverClassName: org.mariadb.jdbc.Driver
2023-10-05T09:29:40,537 INFO [main] org.apache.druid.cli.CliPeon - * druid.metadata.storage.connector.connectURI: jdbc:mariadb://10.10.30.110:3306/druid
2023-10-05T09:29:40,537 INFO [main] org.apache.druid.cli.CliPeon - * druid.metadata.storage.connector.password: <masked>
2023-10-05T09:29:40,537 INFO [main] org.apache.druid.cli.CliPeon - * druid.metadata.storage.connector.user: druid
2023-10-05T09:29:40,538 INFO [main] org.apache.druid.cli.CliPeon - * druid.metadata.storage.type: mysql
2023-10-05T09:29:40,538 INFO [main] org.apache.druid.cli.CliPeon - * druid.metrics.emitter.dimension.dataSource: sms-test-data
2023-10-05T09:29:40,538 INFO [main] org.apache.druid.cli.CliPeon - * druid.metrics.emitter.dimension.taskId: index_kafka_sms-test-data_6656156d2ee944a_hdllhbmo
2023-10-05T09:29:40,538 INFO [main] org.apache.druid.cli.CliPeon - * druid.metrics.emitter.dimension.taskType: index_kafka
2023-10-05T09:29:40,538 INFO [main] org.apache.druid.cli.CliPeon - * druid.monitoring.monitors: ["org.apache.druid.java.util.metrics.JvmMonitor"]
2023-10-05T09:29:40,538 INFO [main] org.apache.druid.cli.CliPeon - * druid.node.type: middleManager
2023-10-05T09:29:40,539 INFO [main] org.apache.druid.cli.CliPeon - * druid.plaintextPort: 8100
2023-10-05T09:29:40,539 INFO [main] org.apache.druid.cli.CliPeon - * druid.processing.buffer.sizeBytes: 100MiB
2023-10-05T09:29:40,539 INFO [main] org.apache.druid.cli.CliPeon - * druid.processing.numMergeBuffers: 2
2023-10-05T09:29:40,539 INFO [main] org.apache.druid.cli.CliPeon - * druid.processing.numThreads: 1
2023-10-05T09:29:40,539 INFO [main] org.apache.druid.cli.CliPeon - * druid.selectors.coordinator.serviceName: druid/coordinator
2023-10-05T09:29:40,540 INFO [main] org.apache.druid.cli.CliPeon - * druid.selectors.indexing.serviceName: druid/overlord
2023-10-05T09:29:40,540 INFO [main] org.apache.druid.cli.CliPeon - * druid.server.hiddenProperties: ["druid.s3.accessKey","druid.s3.secretKey","druid.metadata.storage.connector.password", "password", "key", "token", "pwd"]
2023-10-05T09:29:40,540 INFO [main] org.apache.druid.cli.CliPeon - * druid.server.http.numThreads: 60
2023-10-05T09:29:40,540 INFO [main] org.apache.druid.cli.CliPeon - * druid.service: druid/middleManager
2023-10-05T09:29:40,540 INFO [main] org.apache.druid.cli.CliPeon - * druid.sql.enable: true
2023-10-05T09:29:40,541 INFO [main] org.apache.druid.cli.CliPeon - * druid.sql.planner.useGroupingSetForExactDistinct: true
2023-10-05T09:29:40,541 INFO [main] org.apache.druid.cli.CliPeon - * druid.startup.logging.logProperties: true
2023-10-05T09:29:40,541 INFO [main] org.apache.druid.cli.CliPeon - * druid.storage.storageDirectory: /data/deep/segments
2023-10-05T09:29:40,541 INFO [main] org.apache.druid.cli.CliPeon - * druid.storage.type: local
2023-10-05T09:29:40,542 INFO [main] org.apache.druid.cli.CliPeon - * druid.task.executor.enablePlaintextPort: true
2023-10-05T09:29:40,542 INFO [main] org.apache.druid.cli.CliPeon - * druid.task.executor.enableTlsPort: false
2023-10-05T09:29:40,542 INFO [main] org.apache.druid.cli.CliPeon - * druid.task.executor.host: 10.10.30.113
2023-10-05T09:29:40,543 INFO [main] org.apache.druid.cli.CliPeon - * druid.task.executor.plaintextPort: 8091
2023-10-05T09:29:40,543 INFO [main] org.apache.druid.cli.CliPeon - * druid.task.executor.service: druid/middleManager
2023-10-05T09:29:40,543 INFO [main] org.apache.druid.cli.CliPeon - * druid.task.executor.tlsPort: -1
2023-10-05T09:29:40,543 INFO [main] org.apache.druid.cli.CliPeon - * druid.tlsPort: -1
2023-10-05T09:29:40,544 INFO [main] org.apache.druid.cli.CliPeon - * druid.worker.baseTaskDirs: ["/data/druid/task"]
2023-10-05T09:29:40,544 INFO [main] org.apache.druid.cli.CliPeon - * druid.worker.capacity: 4
2023-10-05T09:29:40,544 INFO [main] org.apache.druid.cli.CliPeon - * druid.zk.paths.base: /data/zk
2023-10-05T09:29:40,544 INFO [main] org.apache.druid.cli.CliPeon - * druid.zk.service.host: 10.10.30.110:2181
2023-10-05T09:29:40,544 INFO [main] org.apache.druid.cli.CliPeon - * file.encoding: UTF-8
2023-10-05T09:29:40,544 INFO [main] org.apache.druid.cli.CliPeon - * file.separator: /
2023-10-05T09:29:40,545 INFO [main] org.apache.druid.cli.CliPeon - * java.awt.graphicsenv: sun.awt.X11GraphicsEnvironment
2023-10-05T09:29:40,545 INFO [main] org.apache.druid.cli.CliPeon - * java.awt.printerjob: sun.print.PSPrinterJob
2023-10-05T09:29:40,545 INFO [main] org.apache.druid.cli.CliPeon - * java.class.path: /data/apache-druid-26.0.0/conf/druid/cluster/data/middleManager:/data/apache-druid-26.0.0/conf/druid/cluster/data/_common:/data/apache-druid-26.0.0/conf/druid/cluster/data/_common/hadoop-xml:/data/apache-druid-26.0.0/conf/druid/cluster/data/../_common:/data/apache-druid-26.0.0/conf/druid/cluster/data/../_common/hadoop-xml:/data/apache-druid-26.0.0/bin/../lib/aws-java-sdk-ec2-1.12.317.jar:/data/apache-druid-26.0.0/bin/../lib/jaxb-api-2.3.1.jar:/data/apache-druid-26.0.0/bin/../lib/jersey-guice-1.19.4.jar:/data/apache-druid-26.0.0/bin/../lib/commons-beanutils-1.9.4.jar:/data/apache-druid-26.0.0/bin/../lib/antlr4-runtime-4.5.1.jar:/data/apache-druid-26.0.0/bin/../lib/jcodings-1.0.43.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-annotations-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/ion-java-1.0.2.jar:/data/apache-druid-26.0.0/bin/../lib/async-http-client-2.5.3.jar:/data/apache-druid-26.0.0/bin/../lib/checker-qual-2.5.7.jar:/data/apache-druid-26.0.0/bin/../lib/jna-4.5.1.jar:/data/apache-druid-26.0.0/bin/../lib/web-console-26.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/shims-0.9.0.jar:/data/apache-druid-26.0.0/bin/../lib/netty-codec-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/google-oauth-client-1.26.0.jar:/data/apache-druid-26.0.0/bin/../lib/javax.inject-1.jar:/data/apache-druid-26.0.0/bin/../lib/vavr-match-0.10.2.jar:/data/apache-druid-26.0.0/bin/../lib/druid-indexing-hadoop-26.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/aws-java-sdk-s3-1.12.317.jar:/data/apache-druid-26.0.0/bin/../lib/protobuf-java-3.21.7.jar:/data/apache-druid-26.0.0/bin/../lib/aether-connector-okhttp-0.0.9.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-dataformat-smile-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-jq-0.0.10.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-io-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/asm-commons-9.3.jar:/data/apache-druid-26.0.0/bin/../lib/json-path-2.3.0.jar:/data/apache-druid-26.0.0/bin/../lib/compress-lzf-1.0.4.jar:/data/apache-druid-26.0.0/bin/../lib/hibernate-validator-5.2.5.Final.jar:/data/apache-druid-26.0.0/bin/../lib/reactive-streams-1.0.2.jar:/data/apache-druid-26.0.0/bin/../lib/javax.activation-api-1.2.0.jar:/data/apache-druid-26.0.0/bin/../lib/maven-model-3.1.1.jar:/data/apache-druid-26.0.0/bin/../lib/guice-4.1.0.jar:/data/apache-druid-26.0.0/bin/../lib/airline-2.8.4.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-core-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/maven-settings-builder-3.1.1.jar:/data/apache-druid-26.0.0/bin/../lib/lz4-java-1.8.0.jar:/data/apache-druid-26.0.0/bin/../lib/aws-java-sdk-sts-1.12.317.jar:/data/apache-druid-26.0.0/bin/../lib/curator-framework-5.4.0.jar:/data/apache-druid-26.0.0/bin/../lib/aether-impl-0.9.0.M2.jar:/data/apache-druid-26.0.0/bin/../lib/okhttp-1.0.2.jar:/data/apache-druid-26.0.0/bin/../lib/druid-processing-26.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-http-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-jaxrs-json-provider-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/istack-commons-runtime-3.0.7.jar:/data/apache-druid-26.0.0/bin/../lib/aopalliance-1.0.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-databind-2.10.5.1.jar:/data/apache-druid-26.0.0/bin/../lib/datasketches-memory-2.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/ipaddress-5.3.4.jar:/data/apache-druid-26.0.0/bin/../lib/jsr311-api-1.1.1.jar:/data/apache-druid-26.0.0/bin/../lib/metrics-core-4.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-rewrite-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/log4j-api-2.18.0.jar:/data/apache-druid-26.0.0/bin/../lib/avatica-server-1.17.0.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-security-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/netty-transport-classes-epoll-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/datasketches-java-3.2.0.jar:/data/apache-druid-26.0.0/bin/../lib/netty-common-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/commons-logging-1.1.1.jar:/data/apache-druid-26.0.0/bin/../lib/httpcore-4.4.11.jar:/data/apache-druid-26.0.0/bin/../lib/log4j-slf4j-impl-2.18.0.jar:/data/apache-druid-26.0.0/bin/../lib/commons-dbcp2-2.0.1.jar:/data/apache-druid-26.0.0/bin/../lib/google-http-client-1.26.0.jar:/data/apache-druid-26.0.0/bin/../lib/netty-handler-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/netty-handler-proxy-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/validation-api-1.1.0.Final.jar:/data/apache-druid-26.0.0/bin/../lib/curator-recipes-5.4.0.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-continuation-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/joni-2.1.27.jar:/data/apache-druid-26.0.0/bin/../lib/jersey-server-1.19.4.jar:/data/apache-druid-26.0.0/bin/../lib/httpclient-4.5.13.jar:/data/apache-druid-26.0.0/bin/../lib/icu4j-55.1.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-client-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/fastutil-core-8.5.4.jar:/data/apache-druid-26.0.0/bin/../lib/maven-artifact-3.6.0.jar:/data/apache-druid-26.0.0/bin/../lib/classmate-1.1.0.jar:/data/apache-druid-26.0.0/bin/../lib/log4j-jul-2.18.0.jar:/data/apache-druid-26.0.0/bin/../lib/jersey-core-1.19.4.jar:/data/apache-druid-26.0.0/bin/../lib/accessors-smart-1.2.jar:/data/apache-druid-26.0.0/bin/../lib/jdbi-2.63.1.jar:/data/apache-druid-26.0.0/bin/../lib/aether-spi-0.9.0.M2.jar:/data/apache-druid-26.0.0/bin/../lib/jboss-logging-3.2.1.Final.jar:/data/apache-druid-26.0.0/bin/../lib/aws-java-sdk-kms-1.12.317.jar:/data/apache-druid-26.0.0/bin/../lib/jsr305-2.0.1.jar:/data/apache-druid-26.0.0/bin/../lib/jakarta.el-3.0.4.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-jaxrs-smile-provider-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/netty-resolver-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/spymemcached-2.12.3.jar:/data/apache-druid-26.0.0/bin/../lib/jmespath-java-1.12.317.jar:/data/apache-druid-26.0.0/bin/../lib/calcite-linq4j-1.21.0.jar:/data/apache-druid-26.0.0/bin/../lib/commons-codec-1.13.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-util-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/curator-x-discovery-5.4.0.jar:/data/apache-druid-26.0.0/bin/../lib/commons-text-1.10.0.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-servlet-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/commons-io-2.11.0.jar:/data/apache-druid-26.0.0/bin/../lib/jaxb-runtime-2.3.1.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-module-jaxb-annotations-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/druid-indexing-service-26.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/log4j-1.2-api-2.18.0.jar:/data/apache-druid-26.0.0/bin/../lib/aggdesigner-algorithm-6.0.jar:/data/apache-druid-26.0.0/bin/../lib/config-magic-0.9.jar:/data/apache-druid-26.0.0/bin/../lib/zookeeper-jute-3.5.10.jar:/data/apache-druid-26.0.0/bin/../lib/commons-math3-3.6.1.jar:/data/apache-druid-26.0.0/bin/../lib/RoaringBitmap-0.9.0.jar:/data/apache-druid-26.0.0/bin/../lib/fastutil-8.5.4.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-jaxrs-base-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/maven-settings-3.1.1.jar:/data/apache-druid-26.0.0/bin/../lib/netty-transport-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/slf4j-api-1.7.36.jar:/data/apache-druid-26.0.0/bin/../lib/maven-model-builder-3.1.1.jar:/data/apache-druid-26.0.0/bin/../lib/tesla-aether-0.0.5.jar:/data/apache-druid-26.0.0/bin/../lib/netty-transport-native-epoll-4.1.86.Final-linux-x86_64.jar:/data/apache-druid-26.0.0/bin/../lib/avatica-metrics-1.17.0.jar:/data/apache-druid-26.0.0/bin/../lib/calcite-core-1.21.0.jar:/data/apache-druid-26.0.0/bin/../lib/jakarta.xml.bind-api-2.3.2.jar:/data/apache-druid-26.0.0/bin/../lib/curator-client-5.4.0.jar:/data/apache-druid-26.0.0/bin/../lib/netty-buffer-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/netty-codec-dns-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/google-http-client-jackson2-1.26.0.jar:/data/apache-druid-26.0.0/bin/../lib/druid-services-26.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/druid-sql-26.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/javax.servlet-api-3.1.0.jar:/data/apache-druid-26.0.0/bin/../lib/aether-api-0.9.0.M2.jar:/data/apache-druid-26.0.0/bin/../lib/resilience4j-core-1.3.1.jar:/data/apache-druid-26.0.0/bin/../lib/janino-3.0.11.jar:/data/apache-druid-26.0.0/bin/../lib/netty-codec-http-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/zookeeper-3.5.10.jar:/data/apache-druid-26.0.0/bin/../lib/joda-time-2.12.4.jar:/data/apache-druid-26.0.0/bin/../lib/commons-collections4-4.2.jar:/data/apache-druid-26.0.0/bin/../lib/guice-assistedinject-4.1.0.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-server-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/jcl-over-slf4j-1.7.36.jar:/data/apache-druid-26.0.0/bin/../lib/derbynet-10.14.2.0.jar:/data/apache-druid-26.0.0/bin/../lib/esri-geometry-api-2.2.0.jar:/data/apache-druid-26.0.0/bin/../lib/netty-codec-socks-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/commons-pool2-2.2.jar:/data/apache-druid-26.0.0/bin/../lib/commons-compiler-3.0.11.jar:/data/apache-druid-26.0.0/bin/../lib/netty-resolver-dns-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/avatica-core-1.17.0.jar:/data/apache-druid-26.0.0/bin/../lib/txw2-2.3.1.jar:/data/apache-druid-26.0.0/bin/../lib/jakarta.activation-api-1.2.1.jar:/data/apache-druid-26.0.0/bin/../lib/netty-transport-native-unix-common-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/javax.activation-1.2.0.jar:/data/apache-druid-26.0.0/bin/../lib/airline-io-2.8.4.jar:/data/apache-druid-26.0.0/bin/../lib/commons-compress-1.21.jar:/data/apache-druid-26.0.0/bin/../lib/guava-16.0.1.jar:/data/apache-druid-26.0.0/bin/../lib/plexus-utils-3.0.24.jar:/data/apache-druid-26.0.0/bin/../lib/vavr-0.10.2.jar:/data/apache-druid-26.0.0/bin/../lib/resilience4j-bulkhead-1.3.1.jar:/data/apache-druid-26.0.0/bin/../lib/maven-aether-provider-3.1.1.jar:/data/apache-druid-26.0.0/bin/../lib/asm-tree-9.3.jar:/data/apache-druid-26.0.0/bin/../lib/google-api-client-1.26.0.jar:/data/apache-druid-26.0.0/bin/../lib/commons-lang-2.6.jar:/data/apache-druid-26.0.0/bin/../lib/wagon-provider-api-2.4.jar:/data/apache-druid-26.0.0/bin/../lib/druid-gcp-common-26.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-module-guice-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/aether-util-0.9.0.M2.jar:/data/apache-druid-26.0.0/bin/../lib/opencsv-4.6.jar:/data/apache-druid-26.0.0/bin/../lib/stax-ex-1.8.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-datatype-guava-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/guice-servlet-4.1.0.jar:/data/apache-druid-26.0.0/bin/../lib/log4j-core-2.18.0.jar:/data/apache-druid-26.0.0/bin/../lib/j2objc-annotations-1.1.jar:/data/apache-druid-26.0.0/bin/../lib/commons-collections-3.2.2.jar:/data/apache-druid-26.0.0/bin/../lib/json-smart-2.3.jar:/data/apache-druid-26.0.0/bin/../lib/guice-multibindings-4.1.0.jar:/data/apache-druid-26.0.0/bin/../lib/error_prone_annotations-2.11.0.jar:/data/apache-druid-26.0.0/bin/../lib/cron-scheduler-0.1.jar:/data/apache-druid-26.0.0/bin/../lib/derby-10.14.2.0.jar:/data/apache-druid-26.0.0/bin/../lib/netty-reactive-streams-2.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/druid-server-26.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/derbyclient-10.14.2.0.jar:/data/apache-druid-26.0.0/bin/../lib/asm-9.3.jar:/data/apache-druid-26.0.0/bin/../lib/druid-aws-common-26.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/rhino-1.7.11.jar:/data/apache-druid-26.0.0/bin/../lib/disruptor-3.3.6.jar:/data/apache-druid-26.0.0/bin/../lib/xz-1.8.jar:/data/apache-druid-26.0.0/bin/../lib/FastInfoset-1.2.15.jar:/data/apache-druid-26.0.0/bin/../lib/asm-analysis-9.3.jar:/data/apache-druid-26.0.0/bin/../lib/zstd-jni-1.5.2-3.jar:/data/apache-druid-26.0.0/bin/../lib/async-http-client-netty-utils-2.5.3.jar:/data/apache-druid-26.0.0/bin/../lib/netty-3.10.6.Final.jar:/data/apache-druid-26.0.0/bin/../lib/plexus-interpolation-1.19.jar:/data/apache-druid-26.0.0/bin/../lib/javax.el-api-3.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-servlets-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-datatype-joda-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/fastutil-extra-8.5.4.jar:/data/apache-druid-26.0.0/bin/../lib/caffeine-2.8.0.jar:/data/apache-druid-26.0.0/bin/../lib/audience-annotations-0.5.0.jar:/data/apache-druid-26.0.0/bin/../lib/commons-lang3-3.12.0.jar:/data/apache-druid-26.0.0/bin/../lib/jersey-servlet-1.19.4.jar:/data/apache-druid-26.0.0/bin/../lib/sigar-1.6.5.132.jar:/data/apache-druid-26.0.0/bin/../lib/maven-repository-metadata-3.1.1.jar:/data/apache-druid-26.0.0/bin/../lib/jakarta.inject-api-1.0.3.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-util-ajax-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-dataformat-cbor-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/aws-java-sdk-core-1.12.317.jar:/data/apache-druid-26.0.0/bin/../lib/aether-connector-file-0.9.0.M2.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-proxy-9.4.48.v20220622.jar
2023-10-05T09:29:40,545 INFO [main] org.apache.druid.cli.CliPeon - * java.class.version: 55.0
2023-10-05T09:29:40,546 INFO [main] org.apache.druid.cli.CliPeon - * java.home: /usr/lib/jvm/java-11-openjdk-amd64
2023-10-05T09:29:40,546 INFO [main] org.apache.druid.cli.CliPeon - * java.io.tmpdir: var/tmp
2023-10-05T09:29:40,547 INFO [main] org.apache.druid.cli.CliPeon - * java.library.path: /usr/java/packages/lib:/usr/lib/x86_64-linux-gnu/jni:/lib/x86_64-linux-gnu:/usr/lib/x86_64-linux-gnu:/usr/lib/jni:/lib:/usr/lib
2023-10-05T09:29:40,547 INFO [main] org.apache.druid.cli.CliPeon - * java.runtime.name: OpenJDK Runtime Environment
2023-10-05T09:29:40,547 INFO [main] org.apache.druid.cli.CliPeon - * java.runtime.version: 11.0.18+10-post-Debian-1deb11u1
2023-10-05T09:29:40,547 INFO [main] org.apache.druid.cli.CliPeon - * java.specification.name: Java Platform API Specification
2023-10-05T09:29:40,548 INFO [main] org.apache.druid.cli.CliPeon - * java.specification.vendor: Oracle Corporation
2023-10-05T09:29:40,548 INFO [main] org.apache.druid.cli.CliPeon - * java.specification.version: 11
2023-10-05T09:29:40,548 INFO [main] org.apache.druid.cli.CliPeon - * java.util.logging.manager: org.apache.logging.log4j.jul.LogManager
2023-10-05T09:29:40,549 INFO [main] org.apache.druid.cli.CliPeon - * java.vendor: Debian
2023-10-05T09:29:40,550 INFO [main] org.apache.druid.cli.CliPeon - * java.vendor.url: https://tracker.debian.org/openjdk-11
2023-10-05T09:29:40,551 INFO [main] org.apache.druid.cli.CliPeon - * java.vendor.url.bug: https://bugs.debian.org/openjdk-11
2023-10-05T09:29:40,551 INFO [main] org.apache.druid.cli.CliPeon - * java.version: 11.0.18
2023-10-05T09:29:40,552 INFO [main] org.apache.druid.cli.CliPeon - * java.version.date: 2023-01-17
2023-10-05T09:29:40,552 INFO [main] org.apache.druid.cli.CliPeon - * java.vm.compressedOopsMode: 32-bit
2023-10-05T09:29:40,552 INFO [main] org.apache.druid.cli.CliPeon - * java.vm.info: mixed mode, sharing
2023-10-05T09:29:40,552 INFO [main] org.apache.druid.cli.CliPeon - * java.vm.name: OpenJDK 64-Bit Server VM
2023-10-05T09:29:40,552 INFO [main] org.apache.druid.cli.CliPeon - * java.vm.specification.name: Java Virtual Machine Specification
2023-10-05T09:29:40,553 INFO [main] org.apache.druid.cli.CliPeon - * java.vm.specification.vendor: Oracle Corporation
2023-10-05T09:29:40,554 INFO [main] org.apache.druid.cli.CliPeon - * java.vm.specification.version: 11
2023-10-05T09:29:40,555 INFO [main] org.apache.druid.cli.CliPeon - * java.vm.vendor: Debian
2023-10-05T09:29:40,556 INFO [main] org.apache.druid.cli.CliPeon - * java.vm.version: 11.0.18+10-post-Debian-1deb11u1
2023-10-05T09:29:40,556 INFO [main] org.apache.druid.cli.CliPeon - * jdk.debug: release
2023-10-05T09:29:40,556 INFO [main] org.apache.druid.cli.CliPeon - * line.separator:
2023-10-05T09:29:40,556 INFO [main] org.apache.druid.cli.CliPeon - * log4j.shutdownCallbackRegistry: org.apache.druid.common.config.Log4jShutdown
2023-10-05T09:29:40,559 INFO [main] org.apache.druid.cli.CliPeon - * log4j.shutdownHookEnabled: true
2023-10-05T09:29:40,560 INFO [main] org.apache.druid.cli.CliPeon - * log4j2.configurationFactory: org.apache.druid.indexing.common.tasklogs.ConsoleLoggingEnforcementConfigurationFactory
2023-10-05T09:29:40,560 INFO [main] org.apache.druid.cli.CliPeon - * log4j2.is.webapp: false
2023-10-05T09:29:40,560 INFO [main] org.apache.druid.cli.CliPeon - * os.arch: amd64
2023-10-05T09:29:40,560 INFO [main] org.apache.druid.cli.CliPeon - * os.name: Linux
2023-10-05T09:29:40,561 INFO [main] org.apache.druid.cli.CliPeon - * os.version: 5.10.0-22-amd64
2023-10-05T09:29:40,562 INFO [main] org.apache.druid.cli.CliPeon - * path.separator: :
2023-10-05T09:29:40,562 INFO [main] org.apache.druid.cli.CliPeon - * sun.arch.data.model: 64
2023-10-05T09:29:40,562 INFO [main] org.apache.druid.cli.CliPeon - * sun.boot.library.path: /usr/lib/jvm/java-11-openjdk-amd64/lib
2023-10-05T09:29:40,562 INFO [main] org.apache.druid.cli.CliPeon - * sun.cpu.endian: little
2023-10-05T09:29:40,562 INFO [main] org.apache.druid.cli.CliPeon - * sun.cpu.isalist:
2023-10-05T09:29:40,562 INFO [main] org.apache.druid.cli.CliPeon - * sun.io.unicode.encoding: UnicodeLittle
2023-10-05T09:29:40,563 INFO [main] org.apache.druid.cli.CliPeon - * sun.java.command: org.apache.druid.cli.Main internal peon /data/druid/task/index_kafka_sms-test-data_6656156d2ee944a_hdllhbmo 1 --loadBroadcastSegments true
2023-10-05T09:29:40,563 INFO [main] org.apache.druid.cli.CliPeon - * sun.java.launcher: SUN_STANDARD
2023-10-05T09:29:40,563 INFO [main] org.apache.druid.cli.CliPeon - * sun.jnu.encoding: UTF-8
2023-10-05T09:29:40,563 INFO [main] org.apache.druid.cli.CliPeon - * sun.management.compiler: HotSpot 64-Bit Tiered Compilers
2023-10-05T09:29:40,564 INFO [main] org.apache.druid.cli.CliPeon - * sun.os.patch.level: unknown
2023-10-05T09:29:40,564 INFO [main] org.apache.druid.cli.CliPeon - * user.country: US
2023-10-05T09:29:40,564 INFO [main] org.apache.druid.cli.CliPeon - * user.dir: /data/apache-druid-26.0.0
2023-10-05T09:29:40,564 INFO [main] org.apache.druid.cli.CliPeon - * user.home: /root
2023-10-05T09:29:40,564 INFO [main] org.apache.druid.cli.CliPeon - * user.language: en
2023-10-05T09:29:40,565 INFO [main] org.apache.druid.cli.CliPeon - * user.name: root
2023-10-05T09:29:40,565 INFO [main] org.apache.druid.cli.CliPeon - * user.timezone: UTC
2023-10-05T09:29:40,607 WARN [main] org.apache.druid.indexing.common.config.TaskConfig - Batch processing mode argument value is null or not valid:[null], defaulting to[CLOSED_SEGMENTS]
2023-10-05T09:29:41,097 INFO [main] org.apache.druid.segment.loading.SegmentLocalCacheManager - Using storage location strategy: [LeastBytesUsedStorageLocationSelectorStrategy]
2023-10-05T09:29:41,166 INFO [main] org.apache.druid.guice.StorageNodeModule - Segment cache not configured on ServerType [indexer-executor]. It will not be assignable for segment placement
2023-10-05T09:29:41,270 INFO [main] org.eclipse.jetty.util.log - Logging initialized @7504ms to org.eclipse.jetty.util.log.Slf4jLog
2023-10-05T09:29:41,287 INFO [main] org.apache.druid.server.initialization.jetty.JettyServerModule - Creating http connector with port [8100]
2023-10-05T09:29:41,426 WARN [main] org.eclipse.jetty.server.handler.gzip.GzipHandler - minGzipSize of 0 is inefficient for short content, break even is size 23
2023-10-05T09:29:41,460 INFO [main] org.apache.druid.offheap.OffheapBufferGenerator - Allocating new intermediate processing buffer[0] of size[104,857,600]
2023-10-05T09:29:41,559 INFO [main] org.apache.druid.offheap.OffheapBufferGenerator - Allocating new result merging buffer[0] of size[104,857,600]
2023-10-05T09:29:41,598 INFO [main] org.apache.druid.offheap.OffheapBufferGenerator - Allocating new result merging buffer[1] of size[104,857,600]
2023-10-05T09:29:41,705 INFO [main] org.apache.druid.java.util.common.lifecycle.Lifecycle - Starting lifecycle [module] stage [INIT]
2023-10-05T09:29:41,706 INFO [main] org.apache.druid.java.util.common.lifecycle.Lifecycle - Starting lifecycle [module] stage [NORMAL]
2023-10-05T09:29:41,720 INFO [main] org.apache.curator.framework.imps.CuratorFrameworkImpl - Starting
2023-10-05T09:29:41,732 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:zookeeper.version=3.5.10-a32c7183d42325b03e44a06aade6a0f16955bf13, built on 05/29/2022 16:59 GMT
2023-10-05T09:29:41,734 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:host.name=druid-data-clone.allip.local
2023-10-05T09:29:41,735 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:java.version=11.0.18
2023-10-05T09:29:41,735 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:java.vendor=Debian
2023-10-05T09:29:41,735 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:java.home=/usr/lib/jvm/java-11-openjdk-amd64
2023-10-05T09:29:41,735 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:java.class.path=/data/apache-druid-26.0.0/conf/druid/cluster/data/middleManager:/data/apache-druid-26.0.0/conf/druid/cluster/data/_common:/data/apache-druid-26.0.0/conf/druid/cluster/data/_common/hadoop-xml:/data/apache-druid-26.0.0/conf/druid/cluster/data/../_common:/data/apache-druid-26.0.0/conf/druid/cluster/data/../_common/hadoop-xml:/data/apache-druid-26.0.0/bin/../lib/aws-java-sdk-ec2-1.12.317.jar:/data/apache-druid-26.0.0/bin/../lib/jaxb-api-2.3.1.jar:/data/apache-druid-26.0.0/bin/../lib/jersey-guice-1.19.4.jar:/data/apache-druid-26.0.0/bin/../lib/commons-beanutils-1.9.4.jar:/data/apache-druid-26.0.0/bin/../lib/antlr4-runtime-4.5.1.jar:/data/apache-druid-26.0.0/bin/../lib/jcodings-1.0.43.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-annotations-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/ion-java-1.0.2.jar:/data/apache-druid-26.0.0/bin/../lib/async-http-client-2.5.3.jar:/data/apache-druid-26.0.0/bin/../lib/checker-qual-2.5.7.jar:/data/apache-druid-26.0.0/bin/../lib/jna-4.5.1.jar:/data/apache-druid-26.0.0/bin/../lib/web-console-26.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/shims-0.9.0.jar:/data/apache-druid-26.0.0/bin/../lib/netty-codec-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/google-oauth-client-1.26.0.jar:/data/apache-druid-26.0.0/bin/../lib/javax.inject-1.jar:/data/apache-druid-26.0.0/bin/../lib/vavr-match-0.10.2.jar:/data/apache-druid-26.0.0/bin/../lib/druid-indexing-hadoop-26.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/aws-java-sdk-s3-1.12.317.jar:/data/apache-druid-26.0.0/bin/../lib/protobuf-java-3.21.7.jar:/data/apache-druid-26.0.0/bin/../lib/aether-connector-okhttp-0.0.9.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-dataformat-smile-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-jq-0.0.10.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-io-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/asm-commons-9.3.jar:/data/apache-druid-26.0.0/bin/../lib/json-path-2.3.0.jar:/data/apache-druid-26.0.0/bin/../lib/compress-lzf-1.0.4.jar:/data/apache-druid-26.0.0/bin/../lib/hibernate-validator-5.2.5.Final.jar:/data/apache-druid-26.0.0/bin/../lib/reactive-streams-1.0.2.jar:/data/apache-druid-26.0.0/bin/../lib/javax.activation-api-1.2.0.jar:/data/apache-druid-26.0.0/bin/../lib/maven-model-3.1.1.jar:/data/apache-druid-26.0.0/bin/../lib/guice-4.1.0.jar:/data/apache-druid-26.0.0/bin/../lib/airline-2.8.4.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-core-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/maven-settings-builder-3.1.1.jar:/data/apache-druid-26.0.0/bin/../lib/lz4-java-1.8.0.jar:/data/apache-druid-26.0.0/bin/../lib/aws-java-sdk-sts-1.12.317.jar:/data/apache-druid-26.0.0/bin/../lib/curator-framework-5.4.0.jar:/data/apache-druid-26.0.0/bin/../lib/aether-impl-0.9.0.M2.jar:/data/apache-druid-26.0.0/bin/../lib/okhttp-1.0.2.jar:/data/apache-druid-26.0.0/bin/../lib/druid-processing-26.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-http-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-jaxrs-json-provider-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/istack-commons-runtime-3.0.7.jar:/data/apache-druid-26.0.0/bin/../lib/aopalliance-1.0.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-databind-2.10.5.1.jar:/data/apache-druid-26.0.0/bin/../lib/datasketches-memory-2.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/ipaddress-5.3.4.jar:/data/apache-druid-26.0.0/bin/../lib/jsr311-api-1.1.1.jar:/data/apache-druid-26.0.0/bin/../lib/metrics-core-4.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-rewrite-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/log4j-api-2.18.0.jar:/data/apache-druid-26.0.0/bin/../lib/avatica-server-1.17.0.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-security-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/netty-transport-classes-epoll-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/datasketches-java-3.2.0.jar:/data/apache-druid-26.0.0/bin/../lib/netty-common-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/commons-logging-1.1.1.jar:/data/apache-druid-26.0.0/bin/../lib/httpcore-4.4.11.jar:/data/apache-druid-26.0.0/bin/../lib/log4j-slf4j-impl-2.18.0.jar:/data/apache-druid-26.0.0/bin/../lib/commons-dbcp2-2.0.1.jar:/data/apache-druid-26.0.0/bin/../lib/google-http-client-1.26.0.jar:/data/apache-druid-26.0.0/bin/../lib/netty-handler-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/netty-handler-proxy-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/validation-api-1.1.0.Final.jar:/data/apache-druid-26.0.0/bin/../lib/curator-recipes-5.4.0.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-continuation-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/joni-2.1.27.jar:/data/apache-druid-26.0.0/bin/../lib/jersey-server-1.19.4.jar:/data/apache-druid-26.0.0/bin/../lib/httpclient-4.5.13.jar:/data/apache-druid-26.0.0/bin/../lib/icu4j-55.1.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-client-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/fastutil-core-8.5.4.jar:/data/apache-druid-26.0.0/bin/../lib/maven-artifact-3.6.0.jar:/data/apache-druid-26.0.0/bin/../lib/classmate-1.1.0.jar:/data/apache-druid-26.0.0/bin/../lib/log4j-jul-2.18.0.jar:/data/apache-druid-26.0.0/bin/../lib/jersey-core-1.19.4.jar:/data/apache-druid-26.0.0/bin/../lib/accessors-smart-1.2.jar:/data/apache-druid-26.0.0/bin/../lib/jdbi-2.63.1.jar:/data/apache-druid-26.0.0/bin/../lib/aether-spi-0.9.0.M2.jar:/data/apache-druid-26.0.0/bin/../lib/jboss-logging-3.2.1.Final.jar:/data/apache-druid-26.0.0/bin/../lib/aws-java-sdk-kms-1.12.317.jar:/data/apache-druid-26.0.0/bin/../lib/jsr305-2.0.1.jar:/data/apache-druid-26.0.0/bin/../lib/jakarta.el-3.0.4.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-jaxrs-smile-provider-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/netty-resolver-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/spymemcached-2.12.3.jar:/data/apache-druid-26.0.0/bin/../lib/jmespath-java-1.12.317.jar:/data/apache-druid-26.0.0/bin/../lib/calcite-linq4j-1.21.0.jar:/data/apache-druid-26.0.0/bin/../lib/commons-codec-1.13.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-util-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/curator-x-discovery-5.4.0.jar:/data/apache-druid-26.0.0/bin/../lib/commons-text-1.10.0.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-servlet-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/commons-io-2.11.0.jar:/data/apache-druid-26.0.0/bin/../lib/jaxb-runtime-2.3.1.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-module-jaxb-annotations-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/druid-indexing-service-26.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/log4j-1.2-api-2.18.0.jar:/data/apache-druid-26.0.0/bin/../lib/aggdesigner-algorithm-6.0.jar:/data/apache-druid-26.0.0/bin/../lib/config-magic-0.9.jar:/data/apache-druid-26.0.0/bin/../lib/zookeeper-jute-3.5.10.jar:/data/apache-druid-26.0.0/bin/../lib/commons-math3-3.6.1.jar:/data/apache-druid-26.0.0/bin/../lib/RoaringBitmap-0.9.0.jar:/data/apache-druid-26.0.0/bin/../lib/fastutil-8.5.4.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-jaxrs-base-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/maven-settings-3.1.1.jar:/data/apache-druid-26.0.0/bin/../lib/netty-transport-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/slf4j-api-1.7.36.jar:/data/apache-druid-26.0.0/bin/../lib/maven-model-builder-3.1.1.jar:/data/apache-druid-26.0.0/bin/../lib/tesla-aether-0.0.5.jar:/data/apache-druid-26.0.0/bin/../lib/netty-transport-native-epoll-4.1.86.Final-linux-x86_64.jar:/data/apache-druid-26.0.0/bin/../lib/avatica-metrics-1.17.0.jar:/data/apache-druid-26.0.0/bin/../lib/calcite-core-1.21.0.jar:/data/apache-druid-26.0.0/bin/../lib/jakarta.xml.bind-api-2.3.2.jar:/data/apache-druid-26.0.0/bin/../lib/curator-client-5.4.0.jar:/data/apache-druid-26.0.0/bin/../lib/netty-buffer-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/netty-codec-dns-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/google-http-client-jackson2-1.26.0.jar:/data/apache-druid-26.0.0/bin/../lib/druid-services-26.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/druid-sql-26.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/javax.servlet-api-3.1.0.jar:/data/apache-druid-26.0.0/bin/../lib/aether-api-0.9.0.M2.jar:/data/apache-druid-26.0.0/bin/../lib/resilience4j-core-1.3.1.jar:/data/apache-druid-26.0.0/bin/../lib/janino-3.0.11.jar:/data/apache-druid-26.0.0/bin/../lib/netty-codec-http-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/zookeeper-3.5.10.jar:/data/apache-druid-26.0.0/bin/../lib/joda-time-2.12.4.jar:/data/apache-druid-26.0.0/bin/../lib/commons-collections4-4.2.jar:/data/apache-druid-26.0.0/bin/../lib/guice-assistedinject-4.1.0.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-server-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/jcl-over-slf4j-1.7.36.jar:/data/apache-druid-26.0.0/bin/../lib/derbynet-10.14.2.0.jar:/data/apache-druid-26.0.0/bin/../lib/esri-geometry-api-2.2.0.jar:/data/apache-druid-26.0.0/bin/../lib/netty-codec-socks-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/commons-pool2-2.2.jar:/data/apache-druid-26.0.0/bin/../lib/commons-compiler-3.0.11.jar:/data/apache-druid-26.0.0/bin/../lib/netty-resolver-dns-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/avatica-core-1.17.0.jar:/data/apache-druid-26.0.0/bin/../lib/txw2-2.3.1.jar:/data/apache-druid-26.0.0/bin/../lib/jakarta.activation-api-1.2.1.jar:/data/apache-druid-26.0.0/bin/../lib/netty-transport-native-unix-common-4.1.86.Final.jar:/data/apache-druid-26.0.0/bin/../lib/javax.activation-1.2.0.jar:/data/apache-druid-26.0.0/bin/../lib/airline-io-2.8.4.jar:/data/apache-druid-26.0.0/bin/../lib/commons-compress-1.21.jar:/data/apache-druid-26.0.0/bin/../lib/guava-16.0.1.jar:/data/apache-druid-26.0.0/bin/../lib/plexus-utils-3.0.24.jar:/data/apache-druid-26.0.0/bin/../lib/vavr-0.10.2.jar:/data/apache-druid-26.0.0/bin/../lib/resilience4j-bulkhead-1.3.1.jar:/data/apache-druid-26.0.0/bin/../lib/maven-aether-provider-3.1.1.jar:/data/apache-druid-26.0.0/bin/../lib/asm-tree-9.3.jar:/data/apache-druid-26.0.0/bin/../lib/google-api-client-1.26.0.jar:/data/apache-druid-26.0.0/bin/../lib/commons-lang-2.6.jar:/data/apache-druid-26.0.0/bin/../lib/wagon-provider-api-2.4.jar:/data/apache-druid-26.0.0/bin/../lib/druid-gcp-common-26.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-module-guice-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/aether-util-0.9.0.M2.jar:/data/apache-druid-26.0.0/bin/../lib/opencsv-4.6.jar:/data/apache-druid-26.0.0/bin/../lib/stax-ex-1.8.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-datatype-guava-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/guice-servlet-4.1.0.jar:/data/apache-druid-26.0.0/bin/../lib/log4j-core-2.18.0.jar:/data/apache-druid-26.0.0/bin/../lib/j2objc-annotations-1.1.jar:/data/apache-druid-26.0.0/bin/../lib/commons-collections-3.2.2.jar:/data/apache-druid-26.0.0/bin/../lib/json-smart-2.3.jar:/data/apache-druid-26.0.0/bin/../lib/guice-multibindings-4.1.0.jar:/data/apache-druid-26.0.0/bin/../lib/error_prone_annotations-2.11.0.jar:/data/apache-druid-26.0.0/bin/../lib/cron-scheduler-0.1.jar:/data/apache-druid-26.0.0/bin/../lib/derby-10.14.2.0.jar:/data/apache-druid-26.0.0/bin/../lib/netty-reactive-streams-2.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/druid-server-26.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/derbyclient-10.14.2.0.jar:/data/apache-druid-26.0.0/bin/../lib/asm-9.3.jar:/data/apache-druid-26.0.0/bin/../lib/druid-aws-common-26.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/rhino-1.7.11.jar:/data/apache-druid-26.0.0/bin/../lib/disruptor-3.3.6.jar:/data/apache-druid-26.0.0/bin/../lib/xz-1.8.jar:/data/apache-druid-26.0.0/bin/../lib/FastInfoset-1.2.15.jar:/data/apache-druid-26.0.0/bin/../lib/asm-analysis-9.3.jar:/data/apache-druid-26.0.0/bin/../lib/zstd-jni-1.5.2-3.jar:/data/apache-druid-26.0.0/bin/../lib/async-http-client-netty-utils-2.5.3.jar:/data/apache-druid-26.0.0/bin/../lib/netty-3.10.6.Final.jar:/data/apache-druid-26.0.0/bin/../lib/plexus-interpolation-1.19.jar:/data/apache-druid-26.0.0/bin/../lib/javax.el-api-3.0.0.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-servlets-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-datatype-joda-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/fastutil-extra-8.5.4.jar:/data/apache-druid-26.0.0/bin/../lib/caffeine-2.8.0.jar:/data/apache-druid-26.0.0/bin/../lib/audience-annotations-0.5.0.jar:/data/apache-druid-26.0.0/bin/../lib/commons-lang3-3.12.0.jar:/data/apache-druid-26.0.0/bin/../lib/jersey-servlet-1.19.4.jar:/data/apache-druid-26.0.0/bin/../lib/sigar-1.6.5.132.jar:/data/apache-druid-26.0.0/bin/../lib/maven-repository-metadata-3.1.1.jar:/data/apache-druid-26.0.0/bin/../lib/jakarta.inject-api-1.0.3.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-util-ajax-9.4.48.v20220622.jar:/data/apache-druid-26.0.0/bin/../lib/jackson-dataformat-cbor-2.10.5.jar:/data/apache-druid-26.0.0/bin/../lib/aws-java-sdk-core-1.12.317.jar:/data/apache-druid-26.0.0/bin/../lib/aether-connector-file-0.9.0.M2.jar:/data/apache-druid-26.0.0/bin/../lib/jetty-proxy-9.4.48.v20220622.jar
2023-10-05T09:29:41,736 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:java.library.path=/usr/java/packages/lib:/usr/lib/x86_64-linux-gnu/jni:/lib/x86_64-linux-gnu:/usr/lib/x86_64-linux-gnu:/usr/lib/jni:/lib:/usr/lib
2023-10-05T09:29:41,737 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:java.io.tmpdir=var/tmp
2023-10-05T09:29:41,737 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:java.compiler=<NA>
2023-10-05T09:29:41,737 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:os.name=Linux
2023-10-05T09:29:41,737 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:os.arch=amd64
2023-10-05T09:29:41,738 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:os.version=5.10.0-22-amd64
2023-10-05T09:29:41,738 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:user.name=root
2023-10-05T09:29:41,738 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:user.home=/root
2023-10-05T09:29:41,740 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:user.dir=/data/apache-druid-26.0.0
2023-10-05T09:29:41,740 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:os.memory.free=889MB
2023-10-05T09:29:41,741 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:os.memory.max=989MB
2023-10-05T09:29:41,741 INFO [main] org.apache.zookeeper.ZooKeeper - Client environment:os.memory.total=989MB
2023-10-05T09:29:41,750 INFO [main] org.apache.zookeeper.ZooKeeper - Initiating client connection, connectString=10.10.30.110:2181 sessionTimeout=30000 watcher=org.apache.curator.ConnectionState@2728add3
2023-10-05T09:29:41,759 INFO [main] org.apache.zookeeper.common.X509Util - Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation
2023-10-05T09:29:41,763 INFO [main] org.apache.zookeeper.ClientCnxnSocket - jute.maxbuffer value is 4194304 Bytes
2023-10-05T09:29:41,774 INFO [main] org.apache.zookeeper.ClientCnxn - zookeeper.request.timeout value is 0. feature enabled=
2023-10-05T09:29:41,805 INFO [main] org.apache.curator.framework.imps.CuratorFrameworkImpl - Default schema
2023-10-05T09:29:41,817 INFO [main-SendThread(10.10.30.110:2181)] org.apache.zookeeper.ClientCnxn - Opening socket connection to server druid-master.allip.local/10.10.30.110:2181. Will not attempt to authenticate using SASL (unknown error)
2023-10-05T09:29:41,837 INFO [main-SendThread(10.10.30.110:2181)] org.apache.zookeeper.ClientCnxn - Socket connection established, initiating session, client: /10.10.30.113:41452, server: druid-master.allip.local/10.10.30.110:2181
2023-10-05T09:29:41,855 INFO [main-SendThread(10.10.30.110:2181)] org.apache.zookeeper.ClientCnxn - Session establishment complete on server druid-master.allip.local/10.10.30.110:2181, sessionid = 0x1004751ff9500cf, negotiated timeout = 30000
2023-10-05T09:29:41,877 INFO [main-EventThread] org.apache.curator.framework.state.ConnectionStateManager - State change: CONNECTED
2023-10-05T09:29:41,898 INFO [main-EventThread] org.apache.curator.framework.imps.EnsembleTracker - New config event received: {}
2023-10-05T09:29:41,898 INFO [main-EventThread] org.apache.curator.framework.imps.EnsembleTracker - New config event received: {}
2023-10-05T09:29:41,929 WARN [NodeRoleWatcher[OVERLORD]] org.apache.druid.curator.discovery.CuratorDruidNodeDiscoveryProvider$NodeRoleWatcher - Ignored event type [CONNECTION_RECONNECTED] for node watcher of role [overlord].
2023-10-05T09:29:41,930 WARN [NodeRoleWatcher[COORDINATOR]] org.apache.druid.curator.discovery.CuratorDruidNodeDiscoveryProvider$NodeRoleWatcher - Ignored event type [CONNECTION_RECONNECTED] for node watcher of role [coordinator].
2023-10-05T09:29:41,952 INFO [NodeRoleWatcher[COORDINATOR]] org.apache.druid.discovery.BaseNodeRoleWatcher - Node [http://10.10.30.110:8081] of role [coordinator] detected.
2023-10-05T09:29:41,953 INFO [NodeRoleWatcher[COORDINATOR]] org.apache.druid.discovery.BaseNodeRoleWatcher - Node watcher of role [coordinator] is now initialized with 1 nodes.
2023-10-05T09:29:41,955 INFO [NodeRoleWatcher[OVERLORD]] org.apache.druid.discovery.BaseNodeRoleWatcher - Node [http://10.10.30.110:8081] of role [overlord] detected.
2023-10-05T09:29:41,955 INFO [NodeRoleWatcher[OVERLORD]] org.apache.druid.discovery.BaseNodeRoleWatcher - Node watcher of role [overlord] is now initialized with 1 nodes.
2023-10-05T09:29:42,028 INFO [main] org.apache.druid.indexing.worker.executor.ExecutorLifecycle - Running with task: {
"type" : "index_kafka",
"id" : "index_kafka_sms-test-data_6656156d2ee944a_hdllhbmo",
"resource" : {
"availabilityGroup" : "index_kafka_sms-test-data_6656156d2ee944a",
"requiredCapacity" : 1
},
"dataSchema" : {
"dataSource" : "sms-test-data",
"timestampSpec" : {
"column" : "DateTime",
"format" : "auto",
"missingValue" : null
},
"dimensionsSpec" : {
"dimensions" : [ {
"type" : "string",
"name" : "InEndpointId",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : true
}, {
"type" : "string",
"name" : "InEndpointRoutingId",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : true
}, {
"type" : "string",
"name" : "InStatus",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : true
}, {
"type" : "string",
"name" : "OutDestination",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : true
}, {
"type" : "string",
"name" : "SubrouteId",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : true
}, {
"type" : "long",
"name" : "OutSeizures",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : false
}, {
"type" : "long",
"name" : "InDlrSeizures",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : false
}, {
"type" : "string",
"name" : "OutStatus",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : true
}, {
"type" : "long",
"name" : "OutDlrSuccess",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : false
}, {
"type" : "long",
"name" : "OutDlrTime",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : false
}, {
"type" : "string",
"name" : "OutEndpointRoutingId",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : true
}, {
"type" : "string",
"name" : "OutEndpointId",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : true
}, {
"type" : "long",
"name" : "InUnits",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : false
}, {
"type" : "string",
"name" : "InDlrStatus",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : true
}, {
"type" : "string",
"name" : "InOrigination",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : true
}, {
"type" : "long",
"name" : "InDlrSuccess",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : false
}, {
"type" : "string",
"name" : "InFinalDlrTimestamp",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : true
}, {
"type" : "string",
"name" : "InDestination",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : true
}, {
"type" : "long",
"name" : "OutUnits",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : false
}, {
"type" : "string",
"name" : "OutDlrStatus",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : true
}, {
"type" : "long",
"name" : "InDlrReceived",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : false
}, {
"type" : "string",
"name" : "RouteId",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : true
}, {
"type" : "long",
"name" : "OutDlrReceived",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : false
}, {
"type" : "string",
"name" : "MlResult",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : true
}, {
"type" : "long",
"name" : "OutDlrSeizures",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : false
}, {
"type" : "long",
"name" : "InDlrTime",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : false
}, {
"type" : "string",
"name" : "OutOrigination",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : true
}, {
"type" : "string",
"name" : "OutFinalDlrTimestamp",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : true
}, {
"type" : "long",
"name" : "InSeizures",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : false
}, {
"type" : "string",
"name" : "TrafficLabel",
"multiValueHandling" : "SORTED_ARRAY",
"createBitmapIndex" : true
} ],
"dimensionExclusions" : [ "__time", "DateTime" ],
"includeAllDimensions" : false,
"useSchemaDiscovery" : false
},
"metricsSpec" : [ ],
"granularitySpec" : {
"type" : "uniform",
"segmentGranularity" : "HOUR",
"queryGranularity" : {
"type" : "none"
},
"rollup" : false,
"intervals" : [ ]
},
"transformSpec" : {
"filter" : null,
"transforms" : [ ]
}
},
"tuningConfig" : {
"type" : "KafkaTuningConfig",
"appendableIndexSpec" : {
"type" : "onheap",
"preserveExistingMetrics" : false
},
"maxRowsInMemory" : 150000,
"maxBytesInMemory" : 0,
"skipBytesInMemoryOverheadCheck" : false,
"maxRowsPerSegment" : 5000000,
"maxTotalRows" : null,
"intermediatePersistPeriod" : "PT10M",
"maxPendingPersists" : 0,
"indexSpec" : {
"bitmap" : {
"type" : "roaring"
},
"dimensionCompression" : "lz4",
"stringDictionaryEncoding" : {
"type" : "utf8"
},
"metricCompression" : "lz4",
"longEncoding" : "longs"
},
"indexSpecForIntermediatePersists" : {
"bitmap" : {
"type" : "roaring"
},
"dimensionCompression" : "lz4",
"stringDictionaryEncoding" : {
"type" : "utf8"
},
"metricCompression" : "lz4",
"longEncoding" : "longs"
},
"reportParseExceptions" : false,
"handoffConditionTimeout" : 0,
"resetOffsetAutomatically" : false,
"segmentWriteOutMediumFactory" : null,
"intermediateHandoffPeriod" : "P2147483647D",
"logParseExceptions" : false,
"maxParseExceptions" : 2147483647,
"maxSavedParseExceptions" : 0,
"skipSequenceNumberAvailabilityCheck" : false
},
"ioConfig" : {
"type" : "kafka",
"taskGroupId" : 0,
"baseSequenceName" : "index_kafka_sms-test-data_6656156d2ee944a",
"startPartitions" : {
"type" : "end",
"stream" : "sms-test-events",
"topic" : "sms-test-events",
"partitionSequenceNumberMap" : {
"0" : 6981,
"1" : 7343,
"2" : 7229,
"3" : 7089,
"4" : 6894
},
"partitionOffsetMap" : {
"0" : 6981,
"1" : 7343,
"2" : 7229,
"3" : 7089,
"4" : 6894
}
},
"endPartitions" : {
"type" : "end",
"stream" : "sms-test-events",
"topic" : "sms-test-events",
"partitionSequenceNumberMap" : {
"0" : 9223372036854775807,
"1" : 9223372036854775807,
"2" : 9223372036854775807,
"3" : 9223372036854775807,
"4" : 9223372036854775807
},
"partitionOffsetMap" : {
"0" : 9223372036854775807,
"1" : 9223372036854775807,
"2" : 9223372036854775807,
"3" : 9223372036854775807,
"4" : 9223372036854775807
}
},
"startSequenceNumbers" : {
"type" : "start",
"stream" : "sms-test-events",
"topic" : "sms-test-events",
"partitionSequenceNumberMap" : {
"0" : 6981,
"1" : 7343,
"2" : 7229,
"3" : 7089,
"4" : 6894
},
"partitionOffsetMap" : {
"0" : 6981,
"1" : 7343,
"2" : 7229,
"3" : 7089,
"4" : 6894
},
"exclusivePartitions" : [ ]
},
"endSequenceNumbers" : {
"type" : "end",
"stream" : "sms-test-events",
"topic" : "sms-test-events",
"partitionSequenceNumberMap" : {
"0" : 9223372036854775807,
"1" : 9223372036854775807,
"2" : 9223372036854775807,
"3" : 9223372036854775807,
"4" : 9223372036854775807
},
"partitionOffsetMap" : {
"0" : 9223372036854775807,
"1" : 9223372036854775807,
"2" : 9223372036854775807,
"3" : 9223372036854775807,
"4" : 9223372036854775807
}
},
"consumerProperties" : {
"bootstrap.servers" : "10.10.30.110:9092,10.10.30.111:9092,10.10.30.112:9092,10.10.30.113:9092"
},
"pollTimeout" : 100,
"useTransaction" : true,
"inputFormat" : {
"type" : "kafka",
"headerFormat" : null,
"keyFormat" : null,
"valueFormat" : {
"type" : "json",
"keepNullColumns" : false,
"assumeNewlineDelimited" : false,
"useJsonNodeReader" : false
},
"headerColumnPrefix" : "kafka.header.",
"keyColumnName" : "kafka.key",
"timestampColumnName" : "kafka.timestamp"
},
"configOverrides" : null
},
"context" : {
"checkpoints" : "{\"0\":{\"0\":6981,\"1\":7343,\"2\":7229,\"3\":7089,\"4\":6894}}",
"useLineageBasedSegmentAllocation" : true,
"IS_INCREMENTAL_HANDOFF_SUPPORTED" : true,
"forceTimeChunkLock" : true
},
"groupId" : "index_kafka_sms-test-data",
"dataSource" : "sms-test-data"
}
2023-10-05T09:29:42,034 INFO [main] org.apache.druid.indexing.worker.executor.ExecutorLifecycle - Attempting to lock file[/data/druid/task/index_kafka_sms-test-data_6656156d2ee944a_hdllhbmo/lock].
2023-10-05T09:29:42,035 INFO [main] org.apache.druid.indexing.worker.executor.ExecutorLifecycle - Acquired lock file[/data/druid/task/index_kafka_sms-test-data_6656156d2ee944a_hdllhbmo/lock] in 1ms.
2023-10-05T09:29:42,039 INFO [main] org.apache.druid.segment.loading.SegmentLocalCacheManager - Using storage location strategy: [LeastBytesUsedStorageLocationSelectorStrategy]
2023-10-05T09:29:42,049 INFO [main] org.apache.druid.server.coordination.SegmentLoadDropHandler - Starting...
2023-10-05T09:29:42,049 INFO [main] org.apache.druid.server.coordination.CuratorDataSegmentServerAnnouncer - Announcing self[DruidServerMetadata{name='10.10.30.113:8100', hostAndPort='10.10.30.113:8100', hostAndTlsPort='null', maxSize=0, tier='_default_tier', type=indexer-executor, priority=0}] at [/data/zk/announcements/10.10.30.113:8100]
2023-10-05T09:29:42,051 INFO [task-runner-0-priority-0] org.apache.druid.indexing.overlord.SingleTaskBackgroundRunner - Running task: index_kafka_sms-test-data_6656156d2ee944a_hdllhbmo
2023-10-05T09:29:42,056 INFO [main] org.apache.druid.server.coordination.SegmentLoadDropHandler - Started.
2023-10-05T09:29:42,059 INFO [main] org.apache.druid.server.coordination.ZkCoordinator - Starting zkCoordinator for server[10.10.30.113:8100]
2023-10-05T09:29:42,088 INFO [main] org.apache.druid.java.util.common.lifecycle.Lifecycle - Starting lifecycle [module] stage [SERVER]
2023-10-05T09:29:42,091 INFO [main] org.eclipse.jetty.server.Server - jetty-9.4.48.v20220622; built: 2022-06-21T20:42:25.880Z; git: 6b67c5719d1f4371b33655ff2d047d24e171e49a; jvm 11.0.18+10-post-Debian-1deb11u1
2023-10-05T09:29:42,172 INFO [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Starting with sequences: [SequenceMetadata{sequenceId=0, sequenceName='index_kafka_sms-test-data_6656156d2ee944a_0', assignments=[0, 1, 2, 3, 4], startOffsets={0=6981, 1=7343, 2=7229, 3=7089, 4=6894}, exclusiveStartPartitions=[], endOffsets={0=9223372036854775807, 1=9223372036854775807, 2=9223372036854775807, 3=9223372036854775807, 4=9223372036854775807}, sentinel=false, checkpointed=false}]
2023-10-05T09:29:42,200 INFO [main] org.eclipse.jetty.server.session - DefaultSessionIdManager workerName=node0
2023-10-05T09:29:42,200 INFO [main] org.eclipse.jetty.server.session - No SessionScavenger set, using defaults
2023-10-05T09:29:42,202 INFO [main] org.eclipse.jetty.server.session - node0 Scavenging every 600000ms
2023-10-05T09:29:42,311 INFO [main] com.sun.jersey.server.impl.application.WebApplicationImpl - Initiating Jersey application, version 'Jersey: 1.19.4 05/24/2017 03:20 PM'
2023-10-05T09:29:42,319 INFO [task-runner-0-priority-0] org.apache.kafka.clients.consumer.ConsumerConfig - ConsumerConfig values:
allow.auto.create.topics = true
auto.commit.interval.ms = 5000
auto.include.jmx.reporter = true
auto.offset.reset = none
bootstrap.servers = [10.10.30.110:9092, 10.10.30.111:9092, 10.10.30.112:9092, 10.10.30.113:9092]
check.crcs = true
client.dns.lookup = use_all_dns_ips
client.id = consumer-kafka-supervisor-cmlbailo-1
client.rack =
connections.max.idle.ms = 540000
default.api.timeout.ms = 60000
enable.auto.commit = false
exclude.internal.topics = true
fetch.max.bytes = 52428800
fetch.max.wait.ms = 500
fetch.min.bytes = 1
group.id = kafka-supervisor-cmlbailo
group.instance.id = null
heartbeat.interval.ms = 3000
interceptor.classes = []
internal.leave.group.on.close = true
internal.throw.on.fetch.stable.offset.unsupported = false
isolation.level = read_committed
key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
max.partition.fetch.bytes = 1048576
max.poll.interval.ms = 300000
max.poll.records = 500
metadata.max.age.ms = 10000
metric.reporters = []
metrics.num.samples = 2
metrics.recording.level = INFO
metrics.sample.window.ms = 30000
partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor]
receive.buffer.bytes = 65536
reconnect.backoff.max.ms = 1000
reconnect.backoff.ms = 50
request.timeout.ms = 30000
retry.backoff.ms = 100
sasl.client.callback.handler.class = null
sasl.jaas.config = null
sasl.kerberos.kinit.cmd = /usr/bin/kinit
sasl.kerberos.min.time.before.relogin = 60000
sasl.kerberos.service.name = null
sasl.kerberos.ticket.renew.jitter = 0.05
sasl.kerberos.ticket.renew.window.factor = 0.8
sasl.login.callback.handler.class = null
sasl.login.class = null
sasl.login.connect.timeout.ms = null
sasl.login.read.timeout.ms = null
sasl.login.refresh.buffer.seconds = 300
sasl.login.refresh.min.period.seconds = 60
sasl.login.refresh.window.factor = 0.8
sasl.login.refresh.window.jitter = 0.05
sasl.login.retry.backoff.max.ms = 10000
sasl.login.retry.backoff.ms = 100
sasl.mechanism = GSSAPI
sasl.oauthbearer.clock.skew.seconds = 30
sasl.oauthbearer.expected.audience = null
sasl.oauthbearer.expected.issuer = null
sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
sasl.oauthbearer.jwks.endpoint.url = null
sasl.oauthbearer.scope.claim.name = scope
sasl.oauthbearer.sub.claim.name = sub
sasl.oauthbearer.token.endpoint.url = null
security.protocol = PLAINTEXT
security.providers = null
send.buffer.bytes = 131072
session.timeout.ms = 45000
socket.connection.setup.timeout.max.ms = 30000
socket.connection.setup.timeout.ms = 10000
ssl.cipher.suites = null
ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
ssl.endpoint.identification.algorithm = https
ssl.engine.factory.class = null
ssl.key.password = null
ssl.keymanager.algorithm = SunX509
ssl.keystore.certificate.chain = null
ssl.keystore.key = null
ssl.keystore.location = null
ssl.keystore.password = null
ssl.keystore.type = JKS
ssl.protocol = TLSv1.3
ssl.provider = null
ssl.secure.random.implementation = null
ssl.trustmanager.algorithm = PKIX
ssl.truststore.certificates = null
ssl.truststore.location = null
ssl.truststore.password = null
ssl.truststore.type = JKS
value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
2023-10-05T09:29:42,776 INFO [task-runner-0-priority-0] org.apache.kafka.common.utils.AppInfoParser - Kafka version: 3.4.0
2023-10-05T09:29:42,776 INFO [task-runner-0-priority-0] org.apache.kafka.common.utils.AppInfoParser - Kafka commitId: 2e1947d240607d53
2023-10-05T09:29:42,776 INFO [task-runner-0-priority-0] org.apache.kafka.common.utils.AppInfoParser - Kafka startTimeMs: 1696498182773
2023-10-05T09:29:42,784 INFO [task-runner-0-priority-0] org.apache.druid.curator.discovery.CuratorDruidNodeAnnouncer - Announced self [{"druidNode":{"service":"druid/middleManager","host":"10.10.30.113","bindOnHost":false,"plaintextPort":8100,"port":-1,"tlsPort":-1,"enablePlaintextPort":true,"enableTlsPort":false},"nodeType":"peon","services":{"dataNodeService":{"type":"dataNodeService","tier":"_default_tier","maxSize":0,"type":"indexer-executor","serverType":"indexer-executor","priority":0},"lookupNodeService":{"type":"lookupNodeService","lookupTier":"__default"}}}].
2023-10-05T09:29:42,866 INFO [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Initialized sequences: SequenceMetadata{sequenceId=0, sequenceName='index_kafka_sms-test-data_6656156d2ee944a_0', assignments=[0, 1, 2, 3, 4], startOffsets={0=6981, 1=7343, 2=7229, 3=7089, 4=6894}, exclusiveStartPartitions=[], endOffsets={0=9223372036854775807, 1=9223372036854775807, 2=9223372036854775807, 3=9223372036854775807, 4=9223372036854775807}, sentinel=false, checkpointed=false}
2023-10-05T09:29:42,873 INFO [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Adding partition[0], start[6981] -> end[9223372036854775807] to assignment.
2023-10-05T09:29:42,873 INFO [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Adding partition[1], start[7343] -> end[9223372036854775807] to assignment.
2023-10-05T09:29:42,874 INFO [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Adding partition[2], start[7229] -> end[9223372036854775807] to assignment.
2023-10-05T09:29:42,874 INFO [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Adding partition[3], start[7089] -> end[9223372036854775807] to assignment.
2023-10-05T09:29:42,874 INFO [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Adding partition[4], start[6894] -> end[9223372036854775807] to assignment.
2023-10-05T09:29:42,876 INFO [task-runner-0-priority-0] org.apache.kafka.clients.consumer.KafkaConsumer - [Consumer clientId=consumer-kafka-supervisor-cmlbailo-1, groupId=kafka-supervisor-cmlbailo] Assigned to partition(s): sms-test-events-1, sms-test-events-0, sms-test-events-3, sms-test-events-2, sms-test-events-4
2023-10-05T09:29:42,883 INFO [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Seeking partition[4] to[6894].
2023-10-05T09:29:42,888 INFO [task-runner-0-priority-0] org.apache.kafka.clients.consumer.KafkaConsumer - [Consumer clientId=consumer-kafka-supervisor-cmlbailo-1, groupId=kafka-supervisor-cmlbailo] Seeking to offset 6894 for partition sms-test-events-4
2023-10-05T09:29:42,892 INFO [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Seeking partition[3] to[7089].
2023-10-05T09:29:42,892 INFO [task-runner-0-priority-0] org.apache.kafka.clients.consumer.KafkaConsumer - [Consumer clientId=consumer-kafka-supervisor-cmlbailo-1, groupId=kafka-supervisor-cmlbailo] Seeking to offset 7089 for partition sms-test-events-3
2023-10-05T09:29:42,892 INFO [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Seeking partition[2] to[7229].
2023-10-05T09:29:42,892 INFO [task-runner-0-priority-0] org.apache.kafka.clients.consumer.KafkaConsumer - [Consumer clientId=consumer-kafka-supervisor-cmlbailo-1, groupId=kafka-supervisor-cmlbailo] Seeking to offset 7229 for partition sms-test-events-2
2023-10-05T09:29:42,892 INFO [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Seeking partition[1] to[7343].
2023-10-05T09:29:42,893 INFO [task-runner-0-priority-0] org.apache.kafka.clients.consumer.KafkaConsumer - [Consumer clientId=consumer-kafka-supervisor-cmlbailo-1, groupId=kafka-supervisor-cmlbailo] Seeking to offset 7343 for partition sms-test-events-1
2023-10-05T09:29:42,893 INFO [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Seeking partition[0] to[6981].
2023-10-05T09:29:42,893 INFO [task-runner-0-priority-0] org.apache.kafka.clients.consumer.KafkaConsumer - [Consumer clientId=consumer-kafka-supervisor-cmlbailo-1, groupId=kafka-supervisor-cmlbailo] Seeking to offset 6981 for partition sms-test-events-0
2023-10-05T09:29:43,262 INFO [main] org.eclipse.jetty.server.handler.ContextHandler - Started o.e.j.s.ServletContextHandler@43cf97a8{/,null,AVAILABLE}
2023-10-05T09:29:43,284 INFO [main] org.eclipse.jetty.server.AbstractConnector - Started ServerConnector@7674f9d4{HTTP/1.1, (http/1.1)}{0.0.0.0:8100}
2023-10-05T09:29:43,288 INFO [main] org.eclipse.jetty.server.Server - Started @9523ms
2023-10-05T09:29:43,288 INFO [main] org.apache.druid.java.util.common.lifecycle.Lifecycle - Starting lifecycle [module] stage [ANNOUNCEMENTS]
2023-10-05T09:29:43,323 INFO [main] org.apache.druid.java.util.common.lifecycle.Lifecycle - Successfully started lifecycle [module]
2023-10-05T09:29:43,766 INFO [task-runner-0-priority-0] org.apache.kafka.clients.Metadata - [Consumer clientId=consumer-kafka-supervisor-cmlbailo-1, groupId=kafka-supervisor-cmlbailo] Resetting the last seen epoch of partition sms-test-events-0 to 51 since the associated topicId changed from null to 7NrOpCaDSwaBErHbCkoPQw
2023-10-05T09:29:43,767 INFO [task-runner-0-priority-0] org.apache.kafka.clients.Metadata - [Consumer clientId=consumer-kafka-supervisor-cmlbailo-1, groupId=kafka-supervisor-cmlbailo] Resetting the last seen epoch of partition sms-test-events-4 to 52 since the associated topicId changed from null to 7NrOpCaDSwaBErHbCkoPQw
2023-10-05T09:29:43,767 INFO [task-runner-0-priority-0] org.apache.kafka.clients.Metadata - [Consumer clientId=consumer-kafka-supervisor-cmlbailo-1, groupId=kafka-supervisor-cmlbailo] Resetting the last seen epoch of partition sms-test-events-1 to 58 since the associated topicId changed from null to 7NrOpCaDSwaBErHbCkoPQw
2023-10-05T09:29:43,767 INFO [task-runner-0-priority-0] org.apache.kafka.clients.Metadata - [Consumer clientId=consumer-kafka-supervisor-cmlbailo-1, groupId=kafka-supervisor-cmlbailo] Resetting the last seen epoch of partition sms-test-events-2 to 52 since the associated topicId changed from null to 7NrOpCaDSwaBErHbCkoPQw
2023-10-05T09:29:43,767 INFO [task-runner-0-priority-0] org.apache.kafka.clients.Metadata - [Consumer clientId=consumer-kafka-supervisor-cmlbailo-1, groupId=kafka-supervisor-cmlbailo] Resetting the last seen epoch of partition sms-test-events-3 to 59 since the associated topicId changed from null to 7NrOpCaDSwaBErHbCkoPQw
2023-10-05T09:29:43,770 INFO [task-runner-0-priority-0] org.apache.kafka.clients.Metadata - [Consumer clientId=consumer-kafka-supervisor-cmlbailo-1, groupId=kafka-supervisor-cmlbailo] Cluster ID: GFheUdOUTIaJChazUuEzrQ
2023-10-05T09:29:44,332 INFO [task-runner-0-priority-0] org.apache.druid.server.coordination.BatchDataSegmentAnnouncer - Announcing segment[sms-test-data_2023-10-02T09:00:00.000Z_2023-10-02T10:00:00.000Z_2023-10-05T08:54:50.739Z] at new path[/data/zk/segments/10.10.30.113:8100/10.10.30.113:8100_indexer-executor__default_tier_2023-10-05T09:29:44.328Z_8baaa0b03d194084ab204f4cf85717c40]
2023-10-05T09:29:45,011 INFO [task-runner-0-priority-0] org.apache.druid.server.coordination.BatchDataSegmentAnnouncer - Announcing segment[sms-test-data_2023-10-02T10:00:00.000Z_2023-10-02T11:00:00.000Z_2023-10-05T08:54:51.412Z] at existing path[/data/zk/segments/10.10.30.113:8100/10.10.30.113:8100_indexer-executor__default_tier_2023-10-05T09:29:44.328Z_8baaa0b03d194084ab204f4cf85717c40]
2023-10-05T09:29:45,678 INFO [task-runner-0-priority-0] org.apache.druid.server.coordination.BatchDataSegmentAnnouncer - Announcing segment[sms-test-data_2023-10-02T12:00:00.000Z_2023-10-02T13:00:00.000Z_2023-10-05T08:54:52.000Z] at existing path[/data/zk/segments/10.10.30.113:8100/10.10.30.113:8100_indexer-executor__default_tier_2023-10-05T09:29:44.328Z_8baaa0b03d194084ab204f4cf85717c40]
2023-10-05T09:29:46,304 INFO [task-runner-0-priority-0] org.apache.druid.server.coordination.BatchDataSegmentAnnouncer - Announcing segment[sms-test-data_2023-10-02T14:00:00.000Z_2023-10-02T15:00:00.000Z_2023-10-05T08:54:52.632Z] at existing path[/data/zk/segments/10.10.30.113:8100/10.10.30.113:8100_indexer-executor__default_tier_2023-10-05T09:29:44.328Z_8baaa0b03d194084ab204f4cf85717c40]
2023-10-05T09:29:46,859 INFO [task-runner-0-priority-0] org.apache.druid.server.coordination.BatchDataSegmentAnnouncer - Announcing segment[sms-test-data_2023-10-02T15:00:00.000Z_2023-10-02T16:00:00.000Z_2023-10-05T08:54:53.220Z] at existing path[/data/zk/segments/10.10.30.113:8100/10.10.30.113:8100_indexer-executor__default_tier_2023-10-05T09:29:44.328Z_8baaa0b03d194084ab204f4cf85717c40]
2023-10-05T09:29:47,457 INFO [task-runner-0-priority-0] org.apache.druid.server.coordination.BatchDataSegmentAnnouncer - Announcing segment[sms-test-data_2023-10-03T13:00:00.000Z_2023-10-03T14:00:00.000Z_2023-10-05T08:54:53.799Z] at existing path[/data/zk/segments/10.10.30.113:8100/10.10.30.113:8100_indexer-executor__default_tier_2023-10-05T09:29:44.328Z_8baaa0b03d194084ab204f4cf85717c40]
2023-10-05T09:29:48,038 INFO [task-runner-0-priority-0] org.apache.druid.server.coordination.BatchDataSegmentAnnouncer - Announcing segment[sms-test-data_2023-10-04T10:00:00.000Z_2023-10-04T11:00:00.000Z_2023-10-05T08:54:54.444Z] at existing path[/data/zk/segments/10.10.30.113:8100/10.10.30.113:8100_indexer-executor__default_tier_2023-10-05T09:29:44.328Z_8baaa0b03d194084ab204f4cf85717c40]
2023-10-05T09:29:48,045 ERROR [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Encountered exception in run() before persisting.
java.lang.NullPointerException: null
at org.apache.druid.segment.realtime.appenderator.BaseAppenderatorDriver.getAppendableSegment(BaseAppenderatorDriver.java:294) ~[druid-server-26.0.0.jar:26.0.0]
at org.apache.druid.segment.realtime.appenderator.BaseAppenderatorDriver.getSegment(BaseAppenderatorDriver.java:332) ~[druid-server-26.0.0.jar:26.0.0]
at org.apache.druid.segment.realtime.appenderator.BaseAppenderatorDriver.append(BaseAppenderatorDriver.java:407) ~[druid-server-26.0.0.jar:26.0.0]
at org.apache.druid.segment.realtime.appenderator.StreamAppenderatorDriver.add(StreamAppenderatorDriver.java:191) ~[druid-server-26.0.0.jar:26.0.0]
at org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner.runInternal(SeekableStreamIndexTaskRunner.java:654) ~[druid-indexing-service-26.0.0.jar:26.0.0]
at org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner.run(SeekableStreamIndexTaskRunner.java:266) ~[druid-indexing-service-26.0.0.jar:26.0.0]
at org.apache.druid.indexing.seekablestream.SeekableStreamIndexTask.runTask(SeekableStreamIndexTask.java:151) ~[druid-indexing-service-26.0.0.jar:26.0.0]
at org.apache.druid.indexing.common.task.AbstractTask.run(AbstractTask.java:173) ~[druid-indexing-service-26.0.0.jar:26.0.0]
at org.apache.druid.indexing.overlord.SingleTaskBackgroundRunner$SingleTaskBackgroundRunnerCallable.call(SingleTaskBackgroundRunner.java:477) ~[druid-indexing-service-26.0.0.jar:26.0.0]
at org.apache.druid.indexing.overlord.SingleTaskBackgroundRunner$SingleTaskBackgroundRunnerCallable.call(SingleTaskBackgroundRunner.java:449) ~[druid-indexing-service-26.0.0.jar:26.0.0]
at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~[?:?]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~[?:?]
at java.lang.Thread.run(Thread.java:829) ~[?:?]
2023-10-05T09:29:48,068 INFO [task-runner-0-priority-0] org.apache.druid.segment.realtime.appenderator.StreamAppenderator - Persisted rows[117] and (estimated) bytes[86,522]
2023-10-05T09:29:48,385 INFO [[index_kafka_sms-test-data_6656156d2ee944a_hdllhbmo]-appenderator-persist] org.apache.druid.segment.realtime.appenderator.StreamAppenderator - Flushed in-memory data for segment[sms-test-data_2023-10-03T13:00:00.000Z_2023-10-03T14:00:00.000Z_2023-10-05T08:54:53.799Z] spill[0] to disk in [316] ms (34 rows).
2023-10-05T09:29:48,493 INFO [[index_kafka_sms-test-data_6656156d2ee944a_hdllhbmo]-appenderator-persist] org.apache.druid.segment.realtime.appenderator.StreamAppenderator - Flushed in-memory data for segment[sms-test-data_2023-10-02T15:00:00.000Z_2023-10-02T16:00:00.000Z_2023-10-05T08:54:53.220Z] spill[0] to disk in [58] ms (16 rows).
2023-10-05T09:29:48,583 INFO [[index_kafka_sms-test-data_6656156d2ee944a_hdllhbmo]-appenderator-persist] org.apache.druid.segment.realtime.appenderator.StreamAppenderator - Flushed in-memory data for segment[sms-test-data_2023-10-02T09:00:00.000Z_2023-10-02T10:00:00.000Z_2023-10-05T08:54:50.739Z] spill[0] to disk in [82] ms (3 rows).
2023-10-05T09:29:48,652 INFO [[index_kafka_sms-test-data_6656156d2ee944a_hdllhbmo]-appenderator-persist] org.apache.druid.segment.realtime.appenderator.StreamAppenderator - Flushed in-memory data for segment[sms-test-data_2023-10-02T10:00:00.000Z_2023-10-02T11:00:00.000Z_2023-10-05T08:54:51.412Z] spill[0] to disk in [54] ms (34 rows).
2023-10-05T09:29:48,703 INFO [[index_kafka_sms-test-data_6656156d2ee944a_hdllhbmo]-appenderator-persist] org.apache.druid.segment.realtime.appenderator.StreamAppenderator - Flushed in-memory data for segment[sms-test-data_2023-10-02T14:00:00.000Z_2023-10-02T15:00:00.000Z_2023-10-05T08:54:52.632Z] spill[0] to disk in [45] ms (1 rows).
2023-10-05T09:29:48,764 INFO [[index_kafka_sms-test-data_6656156d2ee944a_hdllhbmo]-appenderator-persist] org.apache.druid.segment.realtime.appenderator.StreamAppenderator - Flushed in-memory data for segment[sms-test-data_2023-10-04T10:00:00.000Z_2023-10-04T11:00:00.000Z_2023-10-05T08:54:54.444Z] spill[0] to disk in [55] ms (1 rows).
2023-10-05T09:29:48,829 INFO [[index_kafka_sms-test-data_6656156d2ee944a_hdllhbmo]-appenderator-persist] org.apache.druid.segment.realtime.appenderator.StreamAppenderator - Flushed in-memory data for segment[sms-test-data_2023-10-02T12:00:00.000Z_2023-10-02T13:00:00.000Z_2023-10-05T08:54:52.000Z] spill[0] to disk in [59] ms (28 rows).
2023-10-05T09:29:48,850 INFO [[index_kafka_sms-test-data_6656156d2ee944a_hdllhbmo]-appenderator-persist] org.apache.druid.segment.realtime.appenderator.StreamAppenderator - Flushed in-memory data with commit metadata [AppenderatorDriverMetadata{segments={index_kafka_sms-test-data_6656156d2ee944a_0=[SegmentWithState{segmentIdentifier=sms-test-data_2023-10-02T09:00:00.000Z_2023-10-02T10:00:00.000Z_2023-10-05T08:54:50.739Z, state=APPENDING}, SegmentWithState{segmentIdentifier=sms-test-data_2023-10-02T10:00:00.000Z_2023-10-02T11:00:00.000Z_2023-10-05T08:54:51.412Z, state=APPENDING}, SegmentWithState{segmentIdentifier=sms-test-data_2023-10-02T12:00:00.000Z_2023-10-02T13:00:00.000Z_2023-10-05T08:54:52.000Z, state=APPENDING}, SegmentWithState{segmentIdentifier=sms-test-data_2023-10-02T14:00:00.000Z_2023-10-02T15:00:00.000Z_2023-10-05T08:54:52.632Z, state=APPENDING}, SegmentWithState{segmentIdentifier=sms-test-data_2023-10-02T15:00:00.000Z_2023-10-02T16:00:00.000Z_2023-10-05T08:54:53.220Z, state=APPENDING}, SegmentWithState{segmentIdentifier=sms-test-data_2023-10-03T13:00:00.000Z_2023-10-03T14:00:00.000Z_2023-10-05T08:54:53.799Z, state=APPENDING}, SegmentWithState{segmentIdentifier=sms-test-data_2023-10-04T10:00:00.000Z_2023-10-04T11:00:00.000Z_2023-10-05T08:54:54.444Z, state=APPENDING}]}, lastSegmentIds={index_kafka_sms-test-data_6656156d2ee944a_0=sms-test-data_2023-10-04T10:00:00.000Z_2023-10-04T11:00:00.000Z_2023-10-05T08:54:54.444Z}, callerMetadata={nextPartitions=SeekableStreamEndSequenceNumbers{stream='sms-test-events', partitionSequenceNumberMap={0=6981, 1=7343, 2=7229, 3=7206, 4=6894}}}}] for segments: sms-test-data_2023-10-03T13:00:00.000Z_2023-10-03T14:00:00.000Z_2023-10-05T08:54:53.799Z, sms-test-data_2023-10-02T15:00:00.000Z_2023-10-02T16:00:00.000Z_2023-10-05T08:54:53.220Z, sms-test-data_2023-10-02T09:00:00.000Z_2023-10-02T10:00:00.000Z_2023-10-05T08:54:50.739Z, sms-test-data_2023-10-02T10:00:00.000Z_2023-10-02T11:00:00.000Z_2023-10-05T08:54:51.412Z, sms-test-data_2023-10-02T14:00:00.000Z_2023-10-02T15:00:00.000Z_2023-10-05T08:54:52.632Z, sms-test-data_2023-10-04T10:00:00.000Z_2023-10-04T11:00:00.000Z_2023-10-05T08:54:54.444Z, sms-test-data_2023-10-02T12:00:00.000Z_2023-10-02T13:00:00.000Z_2023-10-05T08:54:52.000Z
2023-10-05T09:29:48,851 INFO [[index_kafka_sms-test-data_6656156d2ee944a_hdllhbmo]-appenderator-persist] org.apache.druid.segment.realtime.appenderator.StreamAppenderator - Persisted stats: processed rows: [117], persisted rows[117], sinks: [7], total fireHydrants (across sinks): [7], persisted fireHydrants (across sinks): [7]
2023-10-05T09:29:48,852 INFO [task-runner-0-priority-0] org.apache.kafka.common.metrics.Metrics - Metrics scheduler closed
2023-10-05T09:29:48,858 INFO [task-runner-0-priority-0] org.apache.kafka.common.metrics.Metrics - Closing reporter org.apache.kafka.common.metrics.JmxReporter
2023-10-05T09:29:48,858 INFO [task-runner-0-priority-0] org.apache.kafka.common.metrics.Metrics - Metrics reporters closed
2023-10-05T09:29:48,868 INFO [task-runner-0-priority-0] org.apache.kafka.common.utils.AppInfoParser - App info kafka.consumer for consumer-kafka-supervisor-cmlbailo-1 unregistered
2023-10-05T09:29:48,883 INFO [task-runner-0-priority-0] org.apache.druid.server.coordination.BatchDataSegmentAnnouncer - Unannouncing segment[sms-test-data_2023-10-03T13:00:00.000Z_2023-10-03T14:00:00.000Z_2023-10-05T08:54:53.799Z] at path[/data/zk/segments/10.10.30.113:8100/10.10.30.113:8100_indexer-executor__default_tier_2023-10-05T09:29:44.328Z_8baaa0b03d194084ab204f4cf85717c40]
2023-10-05T09:29:48,900 INFO [task-runner-0-priority-0] org.apache.druid.server.coordination.BatchDataSegmentAnnouncer - Unannouncing segment[sms-test-data_2023-10-02T15:00:00.000Z_2023-10-02T16:00:00.000Z_2023-10-05T08:54:53.220Z] at path[/data/zk/segments/10.10.30.113:8100/10.10.30.113:8100_indexer-executor__default_tier_2023-10-05T09:29:44.328Z_8baaa0b03d194084ab204f4cf85717c40]
2023-10-05T09:29:48,915 INFO [task-runner-0-priority-0] org.apache.druid.server.coordination.BatchDataSegmentAnnouncer - Unannouncing segment[sms-test-data_2023-10-02T09:00:00.000Z_2023-10-02T10:00:00.000Z_2023-10-05T08:54:50.739Z] at path[/data/zk/segments/10.10.30.113:8100/10.10.30.113:8100_indexer-executor__default_tier_2023-10-05T09:29:44.328Z_8baaa0b03d194084ab204f4cf85717c40]
2023-10-05T09:29:48,926 INFO [task-runner-0-priority-0] org.apache.druid.server.coordination.BatchDataSegmentAnnouncer - Unannouncing segment[sms-test-data_2023-10-02T10:00:00.000Z_2023-10-02T11:00:00.000Z_2023-10-05T08:54:51.412Z] at path[/data/zk/segments/10.10.30.113:8100/10.10.30.113:8100_indexer-executor__default_tier_2023-10-05T09:29:44.328Z_8baaa0b03d194084ab204f4cf85717c40]
2023-10-05T09:29:48,937 INFO [task-runner-0-priority-0] org.apache.druid.server.coordination.BatchDataSegmentAnnouncer - Unannouncing segment[sms-test-data_2023-10-02T14:00:00.000Z_2023-10-02T15:00:00.000Z_2023-10-05T08:54:52.632Z] at path[/data/zk/segments/10.10.30.113:8100/10.10.30.113:8100_indexer-executor__default_tier_2023-10-05T09:29:44.328Z_8baaa0b03d194084ab204f4cf85717c40]
2023-10-05T09:29:48,950 INFO [task-runner-0-priority-0] org.apache.druid.server.coordination.BatchDataSegmentAnnouncer - Unannouncing segment[sms-test-data_2023-10-04T10:00:00.000Z_2023-10-04T11:00:00.000Z_2023-10-05T08:54:54.444Z] at path[/data/zk/segments/10.10.30.113:8100/10.10.30.113:8100_indexer-executor__default_tier_2023-10-05T09:29:44.328Z_8baaa0b03d194084ab204f4cf85717c40]
2023-10-05T09:29:48,958 INFO [task-runner-0-priority-0] org.apache.druid.server.coordination.BatchDataSegmentAnnouncer - Unannouncing segment[sms-test-data_2023-10-02T12:00:00.000Z_2023-10-02T13:00:00.000Z_2023-10-05T08:54:52.000Z] at path[/data/zk/segments/10.10.30.113:8100/10.10.30.113:8100_indexer-executor__default_tier_2023-10-05T09:29:44.328Z_8baaa0b03d194084ab204f4cf85717c40]
2023-10-05T09:29:48,958 INFO [task-runner-0-priority-0] org.apache.druid.curator.announcement.Announcer - Unannouncing [/data/zk/segments/10.10.30.113:8100/10.10.30.113:8100_indexer-executor__default_tier_2023-10-05T09:29:44.328Z_8baaa0b03d194084ab204f4cf85717c40]
2023-10-05T09:29:48,975 INFO [task-runner-0-priority-0] org.apache.druid.curator.announcement.Announcer - Unannouncing [/data/zk/internal-discovery/PEON/10.10.30.113:8100]
2023-10-05T09:29:48,978 INFO [task-runner-0-priority-0] org.apache.druid.curator.discovery.CuratorDruidNodeAnnouncer - Unannounced self [{"druidNode":{"service":"druid/middleManager","host":"10.10.30.113","bindOnHost":false,"plaintextPort":8100,"port":-1,"tlsPort":-1,"enablePlaintextPort":true,"enableTlsPort":false},"nodeType":"peon","services":{"dataNodeService":{"type":"dataNodeService","tier":"_default_tier","maxSize":0,"type":"indexer-executor","serverType":"indexer-executor","priority":0},"lookupNodeService":{"type":"lookupNodeService","lookupTier":"__default"}}}].
2023-10-05T09:29:48,979 INFO [task-runner-0-priority-0] org.apache.druid.curator.announcement.Announcer - Unannouncing [/data/zk/announcements/10.10.30.113:8100]
2023-10-05T09:29:48,983 ERROR [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Encountered exception while running task.
java.lang.NullPointerException: null
at org.apache.druid.segment.realtime.appenderator.BaseAppenderatorDriver.getAppendableSegment(BaseAppenderatorDriver.java:294) ~[druid-server-26.0.0.jar:26.0.0]
at org.apache.druid.segment.realtime.appenderator.BaseAppenderatorDriver.getSegment(BaseAppenderatorDriver.java:332) ~[druid-server-26.0.0.jar:26.0.0]
at org.apache.druid.segment.realtime.appenderator.BaseAppenderatorDriver.append(BaseAppenderatorDriver.java:407) ~[druid-server-26.0.0.jar:26.0.0]
at org.apache.druid.segment.realtime.appenderator.StreamAppenderatorDriver.add(StreamAppenderatorDriver.java:191) ~[druid-server-26.0.0.jar:26.0.0]
at org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner.runInternal(SeekableStreamIndexTaskRunner.java:654) ~[druid-indexing-service-26.0.0.jar:26.0.0]
at org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner.run(SeekableStreamIndexTaskRunner.java:266) ~[druid-indexing-service-26.0.0.jar:26.0.0]
at org.apache.druid.indexing.seekablestream.SeekableStreamIndexTask.runTask(SeekableStreamIndexTask.java:151) ~[druid-indexing-service-26.0.0.jar:26.0.0]
at org.apache.druid.indexing.common.task.AbstractTask.run(AbstractTask.java:173) ~[druid-indexing-service-26.0.0.jar:26.0.0]
at org.apache.druid.indexing.overlord.SingleTaskBackgroundRunner$SingleTaskBackgroundRunnerCallable.call(SingleTaskBackgroundRunner.java:477) ~[druid-indexing-service-26.0.0.jar:26.0.0]
at org.apache.druid.indexing.overlord.SingleTaskBackgroundRunner$SingleTaskBackgroundRunnerCallable.call(SingleTaskBackgroundRunner.java:449) ~[druid-indexing-service-26.0.0.jar:26.0.0]
at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~[?:?]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~[?:?]
at java.lang.Thread.run(Thread.java:829) ~[?:?]
2023-10-05T09:29:48,994 INFO [task-runner-0-priority-0] org.apache.druid.indexing.worker.executor.ExecutorLifecycle - Task completed with status: {
"id" : "index_kafka_sms-test-data_6656156d2ee944a_hdllhbmo",
"status" : "FAILED",
"duration" : 6940,
"errorMsg" : "java.lang.NullPointerException\n\tat org.apache.druid.segment.realtime.appenderator.BaseAppenderatorDr...",
"location" : {
"host" : null,
"port" : -1,
"tlsPort" : -1
}
}
2023-10-05T09:29:49,000 INFO [main] org.apache.druid.java.util.common.lifecycle.Lifecycle - Stopping lifecycle [module] stage [ANNOUNCEMENTS]
2023-10-05T09:29:49,020 INFO [main] org.apache.druid.java.util.common.lifecycle.Lifecycle - Stopping lifecycle [module] stage [SERVER]
2023-10-05T09:29:49,032 INFO [main] org.eclipse.jetty.server.AbstractConnector - Stopped ServerConnector@7674f9d4{HTTP/1.1, (http/1.1)}{0.0.0.0:8100}
2023-10-05T09:29:49,032 INFO [main] org.eclipse.jetty.server.session - node0 Stopped scavenging
2023-10-05T09:29:49,034 INFO [main] org.eclipse.jetty.server.handler.ContextHandler - Stopped o.e.j.s.ServletContextHandler@43cf97a8{/,null,STOPPED}
2023-10-05T09:29:49,046 INFO [main] org.apache.druid.java.util.common.lifecycle.Lifecycle - Stopping lifecycle [module] stage [NORMAL]
2023-10-05T09:29:49,046 INFO [main] org.apache.druid.server.coordination.ZkCoordinator - Stopping ZkCoordinator for [DruidServerMetadata{name='10.10.30.113:8100', hostAndPort='10.10.30.113:8100', hostAndTlsPort='null', maxSize=0, tier='_default_tier', type=indexer-executor, priority=0}]
2023-10-05T09:29:49,047 INFO [main] org.apache.druid.server.coordination.SegmentLoadDropHandler - Stopping...
2023-10-05T09:29:49,047 INFO [main] org.apache.druid.server.coordination.SegmentLoadDropHandler - Stopped.
2023-10-05T09:29:49,048 INFO [main] org.apache.druid.indexing.overlord.SingleTaskBackgroundRunner - Starting graceful shutdown of task[index_kafka_sms-test-data_6656156d2ee944a_hdllhbmo].
2023-10-05T09:29:49,048 INFO [main] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Stopping forcefully (status: [READING])
2023-10-05T09:29:49,066 INFO [LookupExtractorFactoryContainerProvider-MainThread] org.apache.druid.query.lookup.LookupReferencesManager - Lookup Management loop exited. Lookup notices are not handled anymore.
2023-10-05T09:29:49,071 INFO [Curator-Framework-0] org.apache.curator.framework.imps.CuratorFrameworkImpl - backgroundOperationsLoop exiting
2023-10-05T09:29:49,178 INFO [main] org.apache.zookeeper.ZooKeeper - Session: 0x1004751ff9500cf closed
2023-10-05T09:29:49,179 INFO [main-EventThread] org.apache.zookeeper.ClientCnxn - EventThread shut down for session: 0x1004751ff9500cf
2023-10-05T09:29:49,204 INFO [main] org.apache.druid.java.util.common.lifecycle.Lifecycle - Stopping lifecycle [module] stage [INIT]
Finished peon task
Sergio Ferragut
Oct 9, 2023, 7:49:54 PM10/9/23
to Druid User
Seems to me like it is running into a bad message. From the code it seems like the timestamp is null.
Perhaps try to set a default value for timestamp in the `missingValue` property of the timestamp spec:
```
"timestampSpec" : {
"column" : "DateTime",
"format" : "auto",
"missingValue" : null
}
"column" : "DateTime",
"format" : "auto",
"missingValue" : null
}
```
Dejan Zegarac
Oct 16, 2023, 5:36:29 AM10/16/23
to Druid User
A full reboot did solve it but seems logical to me as well. Most likely that was the issue indeed. Thanks for your help. I'll update everyone here if the issue happens again in the future and this proves not to be a solution.
Reply all
Reply to author
Forward
0 new messages