successok opened a new issue #11221: URL: https://github.com/apache/druid/issues/11221
### Affected Version the latest version 0.21.0 ### Description As a loyal user of druid, I upgraded the version immediately after it was upgraded to 0.21.0, When I created a datasource from Kafka with old version spec(0.20.2),the task appears to has been completed successfully in task console, and Its status was success, but I can't find it both in the datasource interface and HDFS Deep Storage . From the end of task logs I found the following error message : `2021-05-08T00:58:10,643 WARN [pool-5-thread-2] org.apache.druid.emitter.kafka.KafkaEmitter - Exception while getting record from queue or producer send, Events would not be emitted anymore. java.lang.InterruptedException: null at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.reportInterruptAfterWait(AbstractQueuedSynchronizer.java:2014) ~[?:1.8.0_181] at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2048) ~[?:1.8.0_181] at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ~[?:1.8.0_181] at org.apache.druid.emitter.kafka.MemoryBoundLinkedBlockingQueue.take(MemoryBoundLinkedBlockingQueue.java:59) ~[?:?] at org.apache.druid.emitter.kafka.KafkaEmitter.sendToKafka(KafkaEmitter.java:136) ~[?:?] at org.apache.druid.emitter.kafka.KafkaEmitter.sendAlertToKafka(KafkaEmitter.java:128) ~[?:?] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_181] at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_181] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180) [?:1.8.0_181] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) [?:1.8.0_181] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_181] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_181] at java.lang.Thread.run(Thread.java:748) [?:1.8.0_181]` I know the new version has some changes in ingestion format ,the problem has been solved after reload data from kafka with new spec, but it seems the task status is inaccurate in this version. ![image](https://user-images.githubusercontent.com/50657384/117527024-628d1f80-affb-11eb-8fa9-b17d27f574db.png) -- 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. For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@druid.apache.org For additional commands, e-mail: commits-h...@druid.apache.org