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.
--
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
