githubzxh commented on issue #13418:
URL: https://github.com/apache/druid/issues/13418#issuecomment-1336698592
2022-12-05T03:31:01,545 DEBUG [Coordinator-Exec--0]
org.apache.druid.server.coordinator.duty.LogUsedSegments - Starting
coordination. Getting used segments.
2022-12-05T03:31:01,545 DEBUG [Coordinator-Exec--0]
org.apache.druid.server.coordinator.duty.LogUsedSegments - Used Segments
2022-12-05T03:31:01,545 INFO [Coordinator-Exec--0]
org.apache.druid.server.coordinator.duty.LogUsedSegments - Found [0] used
segments.
2022-12-05T03:31:01,545 DEBUG [Coordinator-Exec--0]
org.apache.druid.server.coordinator.DruidCoordinator - Servers
2022-12-05T03:31:01,546 DEBUG [Coordinator-Exec--0]
org.apache.druid.server.coordinator.DruidCoordinator -
ImmutableDruidServer{meta='DruidServerMetadata{name='localhost:8083',
hostAndPort='localhost:8083', hostAndTlsPort='null', maxSize=300000000000,
tier='_default_tier', type=historical, priority=0}', size='0', sources='{}'}
2022-12-05T03:31:01,546 DEBUG [Coordinator-Exec--0]
org.apache.druid.server.coordinator.DruidCoordinator - -- DataSources
2022-12-05T03:31:01,546 DEBUG [Coordinator-Exec--0]
org.apache.druid.server.coordinator.ServerHolder - Server[localhost:8083],
MaxSize[300,000,000,000], CurrSize[0], QueueSize[0], SizeUsed[0],
AvailableSize[300,000,000,000]
2022-12-05T03:31:01,546 DEBUG [Coordinator-Exec--0]
org.apache.druid.server.coordinator.ServerHolder - Server[localhost:8083],
MaxSize[300,000,000,000], CurrSize[0], QueueSize[0], SizeUsed[0],
AvailableSize[300,000,000,000]
2022-12-05T03:31:01,546 INFO [Coordinator-Exec--0]
org.apache.druid.server.coordinator.ReplicationThrottler - [_default_tier]:
Replicant create queue is empty.
2022-12-05T03:31:01,546 INFO [Coordinator-Exec--0]
org.apache.druid.server.coordinator.duty.BalanceSegments - Metadata segments
are not available. Cannot balance.
2022-12-05T03:31:01,546 INFO [Coordinator-Exec--0]
org.apache.druid.server.coordinator.duty.EmitClusterStatsAndMetrics - Load
Queues:
2022-12-05T03:31:01,546 INFO [Coordinator-Exec--0]
org.apache.druid.server.coordinator.duty.EmitClusterStatsAndMetrics -
Server[localhost:8083, historical, _default_tier] has 0 left to load, 0 left to
drop, 0 served, 0 bytes queued, 0 bytes served.
2022-12-05T03:31:02,061 INFO
[org.apache.druid.metadata.SqlSegmentsMetadataManager-Exec--0]
org.apache.druid.metadata.SqlSegmentsMetadataManager - No segments found in the
database!
2022-12-05T03:31:04,396 INFO [KafkaSupervisor-pointsTaskStatis]
org.apache.druid.indexing.seekablestream.supervisor.SeekableStreamSupervisor -
[pointsTaskStatis] supervisor is running.
2022-12-05T03:31:04,401 WARN [KafkaSupervisor-pointsTaskStatis-Worker-0]
org.apache.druid.indexing.seekablestream.supervisor.SeekableStreamSupervisor -
Clearing task group [0] information as no valid tasks left the group
2022-12-05T03:31:04,401 INFO [KafkaSupervisor-pointsTaskStatis]
org.apache.druid.indexing.seekablestream.supervisor.SeekableStreamSupervisor -
Creating new task group [0] for partitions [0, 1, 2, 3, 4]
2022-12-05T03:31:04,406 INFO [KafkaSupervisor-pointsTaskStatis]
org.apache.kafka.clients.consumer.internals.SubscriptionState - [Consumer
clientId=consumer-kafka-supervisor-gmpjflde-4,
groupId=kafka-supervisor-gmpjflde] Seeking to LATEST offset of partition
pointsTaskStatis-0
2022-12-05T03:31:04,407 INFO [KafkaSupervisor-pointsTaskStatis]
org.apache.kafka.clients.consumer.internals.SubscriptionState - [Consumer
clientId=consumer-kafka-supervisor-gmpjflde-4,
groupId=kafka-supervisor-gmpjflde] Resetting offset for partition
pointsTaskStatis-0 to position FetchPosition{offset=0,
offsetEpoch=Optional.empty,
currentLeader=LeaderAndEpoch{leader=Optional[172.16.238.3:9092 (id: 2 rack:
null)], epoch=4}}.
2022-12-05T03:31:04,407 INFO [KafkaSupervisor-pointsTaskStatis]
org.apache.kafka.clients.consumer.KafkaConsumer - [Consumer
clientId=consumer-kafka-supervisor-gmpjflde-4,
groupId=kafka-supervisor-gmpjflde] Seeking to offset 0 for partition
pointsTaskStatis-0
2022-12-05T03:31:04,412 INFO [KafkaSupervisor-pointsTaskStatis]
org.apache.kafka.clients.consumer.internals.SubscriptionState - [Consumer
clientId=consumer-kafka-supervisor-gmpjflde-4,
groupId=kafka-supervisor-gmpjflde] Seeking to LATEST offset of partition
pointsTaskStatis-1
2022-12-05T03:31:04,413 INFO [KafkaSupervisor-pointsTaskStatis]
org.apache.kafka.clients.consumer.internals.SubscriptionState - [Consumer
clientId=consumer-kafka-supervisor-gmpjflde-4,
groupId=kafka-supervisor-gmpjflde] Resetting offset for partition
pointsTaskStatis-1 to position FetchPosition{offset=0,
offsetEpoch=Optional.empty,
currentLeader=LeaderAndEpoch{leader=Optional[172.16.238.4:9092 (id: 3 rack:
null)], epoch=2}}.
2022-12-05T03:31:04,413 INFO [KafkaSupervisor-pointsTaskStatis]
org.apache.kafka.clients.consumer.KafkaConsumer - [Consumer
clientId=consumer-kafka-supervisor-gmpjflde-4,
groupId=kafka-supervisor-gmpjflde] Seeking to offset 0 for partition
pointsTaskStatis-1
2022-12-05T03:31:04,418 INFO [KafkaSupervisor-pointsTaskStatis]
org.apache.kafka.clients.consumer.internals.SubscriptionState - [Consumer
clientId=consumer-kafka-supervisor-gmpjflde-4,
groupId=kafka-supervisor-gmpjflde] Seeking to LATEST offset of partition
pointsTaskStatis-2
2022-12-05T03:31:04,419 INFO [KafkaSupervisor-pointsTaskStatis]
org.apache.kafka.clients.consumer.internals.SubscriptionState - [Consumer
clientId=consumer-kafka-supervisor-gmpjflde-4,
groupId=kafka-supervisor-gmpjflde] Resetting offset for partition
pointsTaskStatis-2 to position FetchPosition{offset=0,
offsetEpoch=Optional.empty,
currentLeader=LeaderAndEpoch{leader=Optional[172.16.238.2:9092 (id: 1 rack:
null)], epoch=4}}.
2022-12-05T03:31:04,419 INFO [KafkaSupervisor-pointsTaskStatis]
org.apache.kafka.clients.consumer.KafkaConsumer - [Consumer
clientId=consumer-kafka-supervisor-gmpjflde-4,
groupId=kafka-supervisor-gmpjflde] Seeking to offset 0 for partition
pointsTaskStatis-2
2022-12-05T03:31:04,423 INFO [KafkaSupervisor-pointsTaskStatis]
org.apache.kafka.clients.consumer.internals.SubscriptionState - [Consumer
clientId=consumer-kafka-supervisor-gmpjflde-4,
groupId=kafka-supervisor-gmpjflde] Seeking to LATEST offset of partition
pointsTaskStatis-3
2022-12-05T03:31:04,424 INFO [KafkaSupervisor-pointsTaskStatis]
org.apache.kafka.clients.consumer.internals.SubscriptionState - [Consumer
clientId=consumer-kafka-supervisor-gmpjflde-4,
groupId=kafka-supervisor-gmpjflde] Resetting offset for partition
pointsTaskStatis-3 to position FetchPosition{offset=0,
offsetEpoch=Optional.empty,
currentLeader=LeaderAndEpoch{leader=Optional[172.16.238.3:9092 (id: 2 rack:
null)], epoch=4}}.
2022-12-05T03:31:04,424 INFO [KafkaSupervisor-pointsTaskStatis]
org.apache.kafka.clients.consumer.KafkaConsumer - [Consumer
clientId=consumer-kafka-supervisor-gmpjflde-4,
groupId=kafka-supervisor-gmpjflde] Seeking to offset 0 for partition
pointsTaskStatis-3
2022-12-05T03:31:04,429 INFO [KafkaSupervisor-pointsTaskStatis]
org.apache.kafka.clients.consumer.internals.SubscriptionState - [Consumer
clientId=consumer-kafka-supervisor-gmpjflde-4,
groupId=kafka-supervisor-gmpjflde] Seeking to LATEST offset of partition
pointsTaskStatis-4
2022-12-05T03:31:04,430 INFO [KafkaSupervisor-pointsTaskStatis]
org.apache.kafka.clients.consumer.internals.SubscriptionState - [Consumer
clientId=consumer-kafka-supervisor-gmpjflde-4,
groupId=kafka-supervisor-gmpjflde] Resetting offset for partition
pointsTaskStatis-4 to position FetchPosition{offset=0,
offsetEpoch=Optional.empty,
currentLeader=LeaderAndEpoch{leader=Optional[172.16.238.4:9092 (id: 3 rack:
null)], epoch=2}}.
2022-12-05T03:31:04,430 INFO [KafkaSupervisor-pointsTaskStatis]
org.apache.kafka.clients.consumer.KafkaConsumer - [Consumer
clientId=consumer-kafka-supervisor-gmpjflde-4,
groupId=kafka-supervisor-gmpjflde] Seeking to offset 0 for partition
pointsTaskStatis-4
2022-12-05T03:31:04,431 INFO [KafkaSupervisor-pointsTaskStatis]
org.apache.druid.indexing.seekablestream.supervisor.SeekableStreamSupervisor -
Number of tasks [0] does not match configured numReplicas [1] in task group
[0], creating more tasks
2022-12-05T03:31:04,438 INFO [KafkaSupervisor-pointsTaskStatis]
org.apache.druid.indexing.overlord.MetadataTaskStorage - Inserting task
index_kafka_pointsTaskStatis_42cb87c302cf763_pnkpkjjb with status:
TaskStatus{id=index_kafka_pointsTaskStatis_42cb87c302cf763_pnkpkjjb,
status=RUNNING, duration=-1, errorMsg=null}
2022-12-05T03:31:04,447 INFO [KafkaSupervisor-pointsTaskStatis]
org.apache.druid.indexing.overlord.TaskLockbox - Adding
task[index_kafka_pointsTaskStatis_42cb87c302cf763_pnkpkjjb] to activeTasks
2022-12-05T03:31:04,448 INFO [TaskQueue-Manager]
org.apache.druid.indexing.overlord.TaskQueue - Asking taskRunner to run:
index_kafka_pointsTaskStatis_42cb87c302cf763_pnkpkjjb
2022-12-05T03:31:04,448 INFO [TaskQueue-Manager]
org.apache.druid.indexing.overlord.RemoteTaskRunner - Added pending task
index_kafka_pointsTaskStatis_42cb87c302cf763_pnkpkjjb
2022-12-05T03:31:04,448 INFO [KafkaSupervisor-pointsTaskStatis]
org.apache.druid.indexing.seekablestream.supervisor.SeekableStreamSupervisor -
{id='pointsTaskStatis', generationTime=2022-12-05T03:31:04.448Z,
payload=KafkaSupervisorReportPayload{dataSource='pointsTaskStatis',
topic='pointsTaskStatis', partitions=5, replicas=1, durationSeconds=3600,
active=[], publishing=[], suspended=false, healthy=true, state=RUNNING,
detailedState=RUNNING, recentErrors=[]}}
2022-12-05T03:31:04,448 INFO [rtr-pending-tasks-runner-0]
org.apache.druid.indexing.overlord.RemoteTaskRunner - Assigning task
[index_kafka_pointsTaskStatis_42cb87c302cf763_pnkpkjjb] to worker
[localhost:8091]
2022-12-05T03:31:04,453 INFO [rtr-pending-tasks-runner-0]
org.apache.druid.indexing.overlord.RemoteTaskRunner - Task
[index_kafka_pointsTaskStatis_42cb87c302cf763_pnkpkjjb] started running on
worker [localhost:8091]
2022-12-05T03:31:04,472 INFO [Curator-PathChildrenCache-1]
org.apache.druid.indexing.overlord.RemoteTaskRunner - Worker[localhost:8091]
wrote RUNNING status for task
[index_kafka_pointsTaskStatis_42cb87c302cf763_pnkpkjjb] on
[TaskLocation{host='null', port=-1, tlsPort=-1}]
2022-12-05T03:31:04,478 INFO [Curator-PathChildrenCache-1]
org.apache.druid.indexing.overlord.RemoteTaskRunner - Worker[localhost:8091]
wrote RUNNING status for task
[index_kafka_pointsTaskStatis_42cb87c302cf763_pnkpkjjb] on
[TaskLocation{host='localhost', port=8100, tlsPort=-1}]
2022-12-05T03:31:04,539 INFO [Curator-PathChildrenCache-1]
org.apache.druid.indexing.overlord.RemoteTaskRunner - Worker[localhost:8091]
wrote FAILED status for task
[index_kafka_pointsTaskStatis_42cb87c302cf763_pnkpkjjb] on
[TaskLocation{host='localhost', port=8100, tlsPort=-1}]
2022-12-05T03:31:04,540 INFO [Curator-PathChildrenCache-1]
org.apache.druid.indexing.overlord.RemoteTaskRunner - Worker[localhost:8091]
completed task[index_kafka_pointsTaskStatis_42cb87c302cf763_pnkpkjjb] with
status[FAILED]
2022-12-05T03:31:04,540 INFO [Curator-PathChildrenCache-1]
org.apache.druid.indexing.overlord.TaskQueue - Received FAILED status for task:
index_kafka_pointsTaskStatis_42cb87c302cf763_pnkpkjjb
2022-12-05T03:31:04,547 INFO [Curator-PathChildrenCache-1]
org.apache.druid.indexing.overlord.MetadataTaskStorage - Updating task
index_kafka_pointsTaskStatis_42cb87c302cf763_pnkpkjjb to status:
TaskStatus{id=index_kafka_pointsTaskStatis_42cb87c302cf763_pnkpkjjb,
status=FAILED, duration=67, errorMsg=Task execution process exited
unsuccessfully with code[1]. See middleManager logs for more details.}
2022-12-05T03:31:04,556 INFO [Curator-PathChildrenCache-1]
org.apache.druid.indexing.overlord.RemoteTaskRunner - Shutdown
[index_kafka_pointsTaskStatis_42cb87c302cf763_pnkpkjjb] because: [notified
status change from task]
2022-12-05T03:31:04,556 INFO [Curator-PathChildrenCache-1]
org.apache.druid.indexing.overlord.RemoteTaskRunner - Cleaning up
task[index_kafka_pointsTaskStatis_42cb87c302cf763_pnkpkjjb] on
worker[localhost:8091]
2022-12-05T03:31:04,558 INFO [Curator-PathChildrenCache-1]
org.apache.druid.indexing.overlord.TaskLockbox - Removing
task[index_kafka_pointsTaskStatis_42cb87c302cf763_pnkpkjjb] from activeTasks
2022-12-05T03:31:04,558 INFO [Curator-PathChildrenCache-1]
org.apache.druid.indexing.overlord.TaskQueue - Task FAILED:
index_kafka_pointsTaskStatis_42cb87c302cf763_pnkpkjjb (67 run duration)
2022-12-05T03:31:04,559 INFO [Curator-PathChildrenCache-1]
org.apache.druid.indexing.overlord.RemoteTaskRunner -
Task[index_kafka_pointsTaskStatis_42cb87c302cf763_pnkpkjjb] went bye bye.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
