Actually, I used `scheduleWithFixedDelay` not `scheduleAtFixedRate` in my code. 
There may be two EventConsumer tasks at the same time only in the case of 
`flush` method being called. And I fixed it. Thanks for your reminder.
 

[ Full content available at: 
https://github.com/apache/incubator-druid/pull/6251 ]
This message was relayed via gitbox.apache.org for [email protected]

Reply via email to