Unexpected "Triggering JVM shutdown"

Hello,
My druid injestion runs normal where my data bellow 100W/5min
But when my flows reach 1000W/5min,then my druid ingestion task occur something wrong and continued for a long while
Here is my ingestion properties, please give me some help

Status
{
“id”: “index_kafka_test32_8p_p_1_19ed3d8680c1556_cffnmpbe”,
“groupId”: “index_kafka_test32_8p_p_1”,
“type”: “index_kafka”,
“createdTime”: “2021-08-18T01:21:23.887Z”,
“queueInsertionTime”: “1970-01-01T00:00:00.000Z”,
“statusCode”: “FAILED”,
“status”: “FAILED”,
“runnerStatusCode”: “WAITING”,
“duration”: -1,
“location”: {
“host”: “localhost”,
“port”: 8105,
“tlsPort”: -1
},
“dataSource”: “test32_8p_p_1”,
“errorMsg”: null
}

Payload
{
“type”: “index_kafka”,
“id”: “index_kafka_test32_8p_p_1_19ed3d8680c1556_cffnmpbe”,
“resource”: {
“availabilityGroup”: “index_kafka_test32_8p_p_1_19ed3d8680c1556”,
“requiredCapacity”: 1
},
“dataSchema”: {
“dataSource”: “test32_8p_p_1”,
“timestampSpec”: {
“column”: “flowEndSysUpTime”,
“format”: “iso”,
“missingValue”: null
},
“dimensionsSpec”: {
“dimensions”: [
{
“type”: “string”,
“name”: “sourceVmId”,
“multiValueHandling”: “SORTED_ARRAY”,
“createBitmapIndex”: true
},
{
“type”: “string”,
“name”: “destinationIPv4Address”,
“multiValueHandling”: “SORTED_ARRAY”,
“createBitmapIndex”: true
},
{
“type”: “string”,
“name”: “destinationVmId”,
“multiValueHandling”: “SORTED_ARRAY”,
“createBitmapIndex”: true
},
{
“type”: “string”,
“name”: “sourceIPv4Address”,
“multiValueHandling”: “SORTED_ARRAY”,
“createBitmapIndex”: true
},
{
“type”: “string”,
“name”: “destinationTransportPort”,
“multiValueHandling”: “SORTED_ARRAY”,
“createBitmapIndex”: true
},
{
“type”: “string”,
“name”: “flowDirection”,
“multiValueHandling”: “SORTED_ARRAY”,
“createBitmapIndex”: true
},
{
“type”: “string”,
“name”: “flowEndReason”,
“multiValueHandling”: “SORTED_ARRAY”,
“createBitmapIndex”: true
},
{
“type”: “string”,
“name”: “protocolIdentifier”,
“multiValueHandling”: “SORTED_ARRAY”,
“createBitmapIndex”: true
},
{
“type”: “string”,
“name”: “sourceTransportPort”,
“multiValueHandling”: “SORTED_ARRAY”,
“createBitmapIndex”: true
},
{
“type”: “string”,
“name”: “tenantId”,
“multiValueHandling”: “SORTED_ARRAY”,
“createBitmapIndex”: true
}
],
“dimensionExclusions”: [
“flowLiveTime”,
“count”,
“flowEndSysUpTime”,
“octetDeltaCount”,
“packetDeltaCount”
]
},
“metricsSpec”: [
{
“type”: “count”,
“name”: “count”
},
{
“type”: “longSum”,
“name”: “octetDeltaCount”,
“fieldName”: “octetDeltaCount”,
“expression”: null
},
{
“type”: “longSum”,
“name”: “packetDeltaCount”,
“fieldName”: “packetDeltaCount”,
“expression”: null
},
{
“type”: “longSum”,
“name”: “flowLiveTime”,
“fieldName”: “flowLiveTime”,
“expression”: null
}
],
“granularitySpec”: {
“type”: “uniform”,
“segmentGranularity”: “HOUR”,
“queryGranularity”: “SECOND”,
“rollup”: true,
“intervals”: null
},
“transformSpec”: {
“filter”: null,
“transforms”:
}
},
“tuningConfig”: {
“type”: “KafkaTuningConfig”,
“maxRowsInMemory”: 12000000,
“maxBytesInMemory”: 0,
“maxRowsPerSegment”: 12000000,
“maxTotalRows”: null,
“intermediatePersistPeriod”: “PT10M”,
“basePersistDirectory”: “/data/apache-druid-0.19.0/var/tmp/druid-realtime-persist7563132857009259944”,
“maxPendingPersists”: 0,
“indexSpec”: {
“bitmap”: {
“type”: “roaring”,
“compressRunOnSerialization”: true
},
“dimensionCompression”: “lz4”,
“metricCompression”: “lz4”,
“longEncoding”: “longs”,
“segmentLoader”: null
},
“indexSpecForIntermediatePersists”: {
“bitmap”: {
“type”: “roaring”,
“compressRunOnSerialization”: true
},
“dimensionCompression”: “lz4”,
“metricCompression”: “lz4”,
“longEncoding”: “longs”,
“segmentLoader”: null
},
“buildV9Directly”: true,
“reportParseExceptions”: false,
“handoffConditionTimeout”: 0,
“resetOffsetAutomatically”: true,
“segmentWriteOutMediumFactory”: null,
“intermediateHandoffPeriod”: “P2147483647D”,
“logParseExceptions”: false,
“maxParseExceptions”: 2147483647,
“maxSavedParseExceptions”: 0,
“skipSequenceNumberAvailabilityCheck”: false
},
“ioConfig”: {
“type”: “kafka”,
“taskGroupId”: 1,
“baseSequenceName”: “index_kafka_test32_8p_p_1_19ed3d8680c1556”,
“startPartitions”: {
“type”: “end”,
“stream”: “test30_8p_p_1”,
“topic”: “test30_8p_p_1”,
“partitionSequenceNumberMap”: {
“1”: 189964793,
“3”: 190031703,
“5”: 190032453,
“7”: 190002965
},
“partitionOffsetMap”: {
“1”: 189964793,
“3”: 190031703,
“5”: 190032453,
“7”: 190002965
}
},
“endPartitions”: {
“type”: “end”,
“stream”: “test30_8p_p_1”,
“topic”: “test30_8p_p_1”,
“partitionSequenceNumberMap”: {
“1”: 9223372036854776000,
“3”: 9223372036854776000,
“5”: 9223372036854776000,
“7”: 9223372036854776000
},
“partitionOffsetMap”: {
“1”: 9223372036854776000,
“3”: 9223372036854776000,
“5”: 9223372036854776000,
“7”: 9223372036854776000
}
},
“startSequenceNumbers”: {
“type”: “start”,
“stream”: “test30_8p_p_1”,
“topic”: “test30_8p_p_1”,
“partitionSequenceNumberMap”: {
“1”: 189964793,
“3”: 190031703,
“5”: 190032453,
“7”: 190002965
},
“partitionOffsetMap”: {
“1”: 189964793,
“3”: 190031703,
“5”: 190032453,
“7”: 190002965
},
“exclusivePartitions”:
},
“endSequenceNumbers”: {
“type”: “end”,
“stream”: “test30_8p_p_1”,
“topic”: “test30_8p_p_1”,
“partitionSequenceNumberMap”: {
“1”: 9223372036854776000,
“3”: 9223372036854776000,
“5”: 9223372036854776000,
“7”: 9223372036854776000
},
“partitionOffsetMap”: {
“1”: 9223372036854776000,
“3”: 9223372036854776000,
“5”: 9223372036854776000,
“7”: 9223372036854776000
}
},
“consumerProperties”: {
“bootstrap.servers”: “10.109.128.241:9092”
},
“pollTimeout”: 100,
“useTransaction”: true,
“minimumMessageTime”: null,
“maximumMessageTime”: null,
“inputFormat”: {
“type”: “csv”,
“columns”: [
“octetDeltaCount”,
“destinationIPv4Address”,
“flowEndReason”,
“packetDeltaCount”,
“flowDirection”,
“protocolIdentifier”,
“sourceIPv4Address”,
“flowEndSysUpTime”,
“sourceTransportPort”,
“destinationTransportPort”,
“sourceVmId”,
“destinationVmId”,
“flowLiveTime”,
“tenantId”
],
“listDelimiter”: null,
“findColumnsFromHeader”: false,
“skipHeaderRows”: 0
}
},
“context”: {
“checkpoints”: “{“0”:{“1”:189964793,“3”:190031703,“5”:190032453,“7”:190002965}}”,
“IS_INCREMENTAL_HANDOFF_SUPPORTED”: true,
“forceTimeChunkLock”: true
},
“groupId”: “index_kafka_test32_8p_p_1”,
“dataSource”: “test32_8p_p_1”
}

Reports
Request failed with status code 404

Logs
2021-08-18T01:21:29,903 INFO [main] com.sun.jersey.server.impl.application.WebApplicationImpl - Initiating Jersey application, version ‘Jersey: 1.19.3 10/24/2016 03:43 PM’
2021-08-18T01:21:29,953 INFO [task-runner-0-priority-0] org.apache.kafka.common.utils.AppInfoParser - Kafka version: 2.5.0
2021-08-18T01:21:29,954 INFO [task-runner-0-priority-0] org.apache.kafka.common.utils.AppInfoParser - Kafka commitId: 66563e712b0b9f84
2021-08-18T01:21:29,954 INFO [task-runner-0-priority-0] org.apache.kafka.common.utils.AppInfoParser - Kafka startTimeMs: 1629249689948
2021-08-18T01:21:29,955 INFO [task-runner-0-priority-0] org.apache.druid.server.coordination.CuratorDataSegmentServerAnnouncer - Announcing self[DruidServerMetadata{name=‘localhost:8105’, hostAndPort=‘localhost:8105’, hostAndTlsPort=‘null’, maxSize=0, tier=’_default_tier’, type=indexer-executor, priority=0}] at [/druid/announcements/localhost:8105]
2021-08-18T01:21:29,965 INFO [task-runner-0-priority-0] org.apache.druid.curator.discovery.CuratorDruidNodeAnnouncer - Announced self [{“druidNode”:{“service”:“druid/middleManager”,“host”:“localhost”,“bindOnHost”:false,“plaintextPort”:8105,“port”:-1,“tlsPort”:-1,“enablePlaintextPort”:true,“enableTlsPort”:false},“nodeType”:“peon”,“services”:{“dataNodeService”:{“type”:“dataNodeService”,“tier”:"_default_tier",“maxSize”:0,“type”:“indexer-executor”,“priority”:0},“lookupNodeService”:{“type”:“lookupNodeService”,“lookupTier”:"__default"}}}].
2021-08-18T01:21:30,013 INFO [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Initialized sequences: SequenceMetadata{sequenceId=0, sequenceName=‘index_kafka_test32_8p_p_1_19ed3d8680c1556_0’, assignments=[1, 3, 5, 7], startOffsets={1=189964793, 3=190031703, 5=190032453, 7=190002965}, exclusiveStartPartitions=, endOffsets={1=9223372036854775807, 3=9223372036854775807, 5=9223372036854775807, 7=9223372036854775807}, sentinel=false, checkpointed=false}
2021-08-18T01:21:30,015 INFO [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Adding partition[1], start[189964793] → end[9223372036854775807] to assignment.
2021-08-18T01:21:30,015 INFO [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Adding partition[3], start[190031703] → end[9223372036854775807] to assignment.
2021-08-18T01:21:30,015 INFO [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Adding partition[5], start[190032453] → end[9223372036854775807] to assignment.
2021-08-18T01:21:30,015 INFO [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Adding partition[7], start[190002965] → end[9223372036854775807] to assignment.
2021-08-18T01:21:30,018 INFO [task-runner-0-priority-0] org.apache.kafka.clients.consumer.KafkaConsumer - [Consumer clientId=consumer-kafka-supervisor-ihaamlgk-1, groupId=kafka-supervisor-ihaamlgk] Subscribed to partition(s): test30_8p_p_1-3, test30_8p_p_1-1, test30_8p_p_1-7, test30_8p_p_1-5
2021-08-18T01:21:30,022 INFO [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Seeking partition[7] to[190002965].
2021-08-18T01:21:30,023 INFO [task-runner-0-priority-0] org.apache.kafka.clients.consumer.KafkaConsumer - [Consumer clientId=consumer-kafka-supervisor-ihaamlgk-1, groupId=kafka-supervisor-ihaamlgk] Seeking to offset 190002965 for partition test30_8p_p_1-7
2021-08-18T01:21:30,025 INFO [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Seeking partition[5] to[190032453].
2021-08-18T01:21:30,025 INFO [task-runner-0-priority-0] org.apache.kafka.clients.consumer.KafkaConsumer - [Consumer clientId=consumer-kafka-supervisor-ihaamlgk-1, groupId=kafka-supervisor-ihaamlgk] Seeking to offset 190032453 for partition test30_8p_p_1-5
2021-08-18T01:21:30,025 INFO [task-runner-0-priority-0] org.apache.kafka.clients.consumer.KafkaConsumer - [Consumer clientId=consumer-kafka-supervisor-ihaamlgk-1, groupId=kafka-supervisor-ihaamlgk] Seeking to offset 189964793 for partition test30_8p_p_1-1
2021-08-18T01:21:30,618 INFO [main] org.eclipse.jetty.server.handler.ContextHandler - Started o.e.j.s.ServletContextHandler@31b6fb14{/,null,AVAILABLE}
2021-08-18T01:21:30,636 INFO [main] org.eclipse.jetty.server.AbstractConnector - Started ServerConnector@18513c23{HTTP/1.1,[http/1.1]}{0.0.0.0:8105}
2021-08-18T01:21:30,637 INFO [main] org.eclipse.jetty.server.Server - Started @6648ms
2021-08-18T01:21:30,638 INFO [main] org.apache.druid.java.util.common.lifecycle.Lifecycle - Starting lifecycle [module] stage [ANNOUNCEMENTS]
2021-08-18T01:21:30,677 INFO [main] org.apache.druid.java.util.common.lifecycle.Lifecycle - Successfully started lifecycle [module]
2021-08-18T01:21:30,701 INFO [task-runner-0-priority-0] org.apache.kafka.clients.Metadata - [Consumer clientId=consumer-kafka-supervisor-ihaamlgk-1, groupId=kafka-supervisor-ihaamlgk] Cluster ID: u8011xPVQHaEJkqCbCIuYA
2021-08-18T01:23:17,843 INFO [parent-monitor-0] org.apache.druid.indexing.worker.executor.ExecutorLifecycle - Triggering JVM shutdown.
2021-08-18T01:23:17,844 INFO [Thread-63] org.apache.druid.cli.CliPeon - Running shutdown hook
2021-08-18T01:23:17,846 INFO [Thread-63] org.apache.druid.java.util.common.lifecycle.Lifecycle - Stopping lifecycle [module] stage [ANNOUNCEMENTS]
2021-08-18T01:23:17,849 INFO [Thread-63] org.apache.druid.curator.announcement.Announcer - Unannouncing [/druid/announcements/localhost:8105]
2021-08-18T01:23:17,878 INFO [Thread-63] org.apache.druid.curator.announcement.Announcer - Unannouncing [/druid/internal-discovery/PEON/localhost:8105]
2021-08-18T01:23:17,900 INFO [Thread-63] org.apache.druid.java.util.common.lifecycle.Lifecycle - Stopping lifecycle [module] stage [SERVER]
2021-08-18T01:23:17,906 INFO [Thread-63] org.eclipse.jetty.server.AbstractConnector - Stopped ServerConnector@18513c23{HTTP/1.1,[http/1.1]}{0.0.0.0:8105}
2021-08-18T01:23:17,907 INFO [Thread-63] org.eclipse.jetty.server.session - node0 Stopped scavenging
2021-08-18T01:23:17,910 INFO [Thread-63] org.eclipse.jetty.server.handler.ContextHandler - Stopped o.e.j.s.ServletContextHandler@31b6fb14{/,null,UNAVAILABLE}
2021-08-18T01:23:17,916 INFO [Thread-63] org.apache.druid.java.util.common.lifecycle.Lifecycle - Stopping lifecycle [module] stage [NORMAL]
2021-08-18T01:23:17,916 INFO [Thread-63] org.apache.druid.server.coordination.ZkCoordinator - Stopping ZkCoordinator for [DruidServerMetadata{name=‘localhost:8105’, hostAndPort=‘localhost:8105’, hostAndTlsPort=‘null’, maxSize=0, tier=’_default_tier’, type=indexer-executor, priority=0}]
2021-08-18T01:23:17,917 INFO [Thread-63] org.apache.druid.server.coordination.SegmentLoadDropHandler - Stopping…
2021-08-18T01:23:17,917 INFO [Thread-63] org.apache.druid.server.coordination.SegmentLoadDropHandler - Stopped.
2021-08-18T01:23:17,918 INFO [Thread-63] org.apache.druid.indexing.overlord.SingleTaskBackgroundRunner - Starting graceful shutdown of task[index_kafka_test32_8p_p_1_19ed3d8680c1556_cffnmpbe].
2021-08-18T01:23:17,918 INFO [Thread-63] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Stopping forcefully (status: [READING])
2021-08-18T01:23:17,922 INFO [LookupExtractorFactoryContainerProvider-MainThread] org.apache.druid.query.lookup.LookupReferencesManager - Lookup Management loop exited. Lookup notices are not handled anymore.
2021-08-18T01:23:17,920 ERROR [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Encountered exception in run() before persisting.
org.apache.kafka.common.errors.InterruptException: java.lang.InterruptedException
at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.maybeThrowInterruptException(ConsumerNetworkClient.java:517) ~[?:?]
at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:278) ~[?:?]
at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:233) ~[?:?]
at org.apache.kafka.clients.consumer.KafkaConsumer.pollForFetches(KafkaConsumer.java:1308) ~[?:?]
at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1248) ~[?:?]
at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1216) ~[?:?]
at org.apache.druid.indexing.kafka.KafkaRecordSupplier.poll(KafkaRecordSupplier.java:124) ~[?:?]
at org.apache.druid.indexing.kafka.IncrementalPublishingKafkaIndexTaskRunner.getRecords(IncrementalPublishingKafkaIndexTaskRunner.java:111) ~[?:?]
at org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner.runInternal(SeekableStreamIndexTaskRunner.java:605) [druid-indexing-service-0.19.0.jar:0.19.0]
at org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner.run(SeekableStreamIndexTaskRunner.java:277) [druid-indexing-service-0.19.0.jar:0.19.0]
at org.apache.druid.indexing.seekablestream.SeekableStreamIndexTask.run(SeekableStreamIndexTask.java:164) [druid-indexing-service-0.19.0.jar:0.19.0]
at org.apache.druid.indexing.overlord.SingleTaskBackgroundRunner$SingleTaskBackgroundRunnerCallable.call(SingleTaskBackgroundRunner.java:421) [druid-indexing-service-0.19.0.jar:0.19.0]
at org.apache.druid.indexing.overlord.SingleTaskBackgroundRunner$SingleTaskBackgroundRunnerCallable.call(SingleTaskBackgroundRunner.java:393) [druid-indexing-service-0.19.0.jar:0.19.0]
at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_292]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_292]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_292]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_292]
Caused by: java.lang.InterruptedException
… 17 more
2021-08-18T01:23:17,942 INFO [Curator-Framework-0] org.apache.curator.framework.imps.CuratorFrameworkImpl - backgroundOperationsLoop exiting
2021-08-18T01:23:17,958 INFO [[index_kafka_test32_8p_p_1_19ed3d8680c1556_cffnmpbe]-appenderator-persist] org.apache.druid.segment.realtime.appenderator.AppenderatorImpl - Flushed in-memory data with commit metadata [AppenderatorDriverMetadata{segments={}, lastSegmentIds={}, callerMetadata={nextPartitions=SeekableStreamEndSequenceNumbers{stream=‘test30_8p_p_1’, partitionSequenceNumberMap={1=189964793, 3=190031703, 5=190032453, 7=190002965}}}}] for segments:
2021-08-18T01:23:17,958 INFO [Thread-63] org.apache.zookeeper.ZooKeeper - Session: 0x100592bae9d0130 closed
2021-08-18T01:23:17,958 INFO [Thread-63] org.apache.druid.java.util.common.lifecycle.Lifecycle - Stopping lifecycle [module] stage [INIT]
2021-08-18T01:23:17,958 INFO [main-EventThread] org.apache.zookeeper.ClientCnxn - EventThread shut down for session: 0x100592bae9d0130
2021-08-18T01:23:17,959 INFO [task-runner-0-priority-0] org.apache.druid.curator.discovery.CuratorDruidNodeAnnouncer - Unannounced self [{“druidNode”:{“service”:“druid/middleManager”,“host”:“localhost”,“bindOnHost”:false,“plaintextPort”:8105,“port”:-1,“tlsPort”:-1,“enablePlaintextPort”:true,“enableTlsPort”:false},“nodeType”:“peon”,“services”:{“dataNodeService”:{“type”:“dataNodeService”,“tier”:"_default_tier",“maxSize”:0,“type”:“indexer-executor”,“priority”:0},“lookupNodeService”:{“type”:“lookupNodeService”,“lookupTier”:"__default"}}}].
2021-08-18T01:23:17,959 ERROR [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Encountered exception while running task.
org.apache.kafka.common.errors.InterruptException: java.lang.InterruptedException
at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.maybeThrowInterruptException(ConsumerNetworkClient.java:517) ~[?:?]
at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:278) ~[?:?]
at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:233) ~[?:?]
at org.apache.kafka.clients.consumer.KafkaConsumer.pollForFetches(KafkaConsumer.java:1308) ~[?:?]
at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1248) ~[?:?]
at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1216) ~[?:?]
at org.apache.druid.indexing.kafka.KafkaRecordSupplier.poll(KafkaRecordSupplier.java:124) ~[?:?]
at org.apache.druid.indexing.kafka.IncrementalPublishingKafkaIndexTaskRunner.getRecords(IncrementalPublishingKafkaIndexTaskRunner.java:111) ~[?:?]
at org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner.runInternal(SeekableStreamIndexTaskRunner.java:605) ~[druid-indexing-service-0.19.0.jar:0.19.0]
at org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner.run(SeekableStreamIndexTaskRunner.java:277) [druid-indexing-service-0.19.0.jar:0.19.0]
at org.apache.druid.indexing.seekablestream.SeekableStreamIndexTask.run(SeekableStreamIndexTask.java:164) [druid-indexing-service-0.19.0.jar:0.19.0]
at org.apache.druid.indexing.overlord.SingleTaskBackgroundRunner$SingleTaskBackgroundRunnerCallable.call(SingleTaskBackgroundRunner.java:421) [druid-indexing-service-0.19.0.jar:0.19.0]
at org.apache.druid.indexing.overlord.SingleTaskBackgroundRunner$SingleTaskBackgroundRunnerCallable.call(SingleTaskBackgroundRunner.java:393) [druid-indexing-service-0.19.0.jar:0.19.0]
at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_292]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_292]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_292]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_292]
Suppressed: java.lang.InterruptedException
at java.util.concurrent.FutureTask.awaitDone(FutureTask.java:404) ~[?:1.8.0_292]
at java.util.concurrent.FutureTask.get(FutureTask.java:191) ~[?:1.8.0_292]
at org.apache.druid.segment.realtime.appenderator.StreamAppenderatorDriver.persist(StreamAppenderatorDriver.java:231) ~[druid-server-0.19.0.jar:0.19.0]
at org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner.runInternal(SeekableStreamIndexTaskRunner.java:778) ~[druid-indexing-service-0.19.0.jar:0.19.0]
at org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner.run(SeekableStreamIndexTaskRunner.java:277) [druid-indexing-service-0.19.0.jar:0.19.0]
at org.apache.druid.indexing.seekablestream.SeekableStreamIndexTask.run(SeekableStreamIndexTask.java:164) [druid-indexing-service-0.19.0.jar:0.19.0]
at org.apache.druid.indexing.overlord.SingleTaskBackgroundRunner$SingleTaskBackgroundRunnerCallable.call(SingleTaskBackgroundRunner.java:421) [druid-indexing-service-0.19.0.jar:0.19.0]
at org.apache.druid.indexing.overlord.SingleTaskBackgroundRunner$SingleTaskBackgroundRunnerCallable.call(SingleTaskBackgroundRunner.java:393) [druid-indexing-service-0.19.0.jar:0.19.0]
at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_292]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_292]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_292]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_292]
Caused by: java.lang.InterruptedException
… 17 more