2023-01-09T090116,564 INFO [Curator-PathChildrenCache-1] org.apache.druid.indexing.overlord.RemoteTaskRunner - Worker[druid-indexer-v6fw:8091] completed task[index_kafka_beam-advanced_9e22ee33bec07d0_alaobbia] with status[SUCCESS] 2023-01-09T090116,564 INFO [Curator-PathChildrenCache-1] org.apache.druid.indexing.overlord.TaskQueue - Received SUCCESS status for task: index_kafka_beam-advanced_9e22ee33bec07d0_alaobbia 2023-01-09T090116,566 ERROR [Curator-PathChildrenCache-1] org.apache.druid.indexing.overlord.TaskQueue - Ignoring notification for already-complete task: {class=org.apache.druid.indexing.overlord.TaskQueue, task=index_kafka_beam-advanced_9e22ee33bec07d0_alaobbia} 2023-01-09T090116,566 INFO [Curator-PathChildrenCache-1] org.apache.druid.indexing.overlord.RemoteTaskRunner - Shutdown [index_kafka_beam-advanced_9e22ee33bec07d0_alaobbia] because: [notified status change from task] 2023-01-09T090116,566 INFO [Curator-PathChildrenCache-1] org.apache.druid.indexing.overlord.RemoteTaskRunner - Cleaning up task[index_kafka_beam-advanced_9e22ee33bec07d0_alaobbia] on worker[druid-indexer-v6fw:8091] 2023-01-09T090116,567 WARN [Curator-PathChildrenCache-1] org.apache.druid.indexing.overlord.TaskQueue - Unknown task completed: index_kafka_beam-advanced_9e22ee33bec07d0_alaobbia 2023-01-09T090116,567 INFO [Curator-PathChildrenCache-1] org.apache.druid.indexing.overlord.TaskQueue - Task SUCCESS: index_kafka_beam-advanced_9e22ee33bec07d0_alaobbia (1878459 run duration) 2023-01-09T090116,568 INFO [Curator-PathChildrenCache-1] org.apache.druid.indexing.overlord.RemoteTaskRunner - Task[index_kafka_beam-advanced_9e22ee33bec07d0_alaobbia] went bye bye.