[#6251](https://github.com/apache/incubator-druid/pull/6251/files) uses 
ScheduledExecutorService to schedule. But if emitter has large amounts data 
continuously, eventQueue always has element, there will be multiple 
EventConsumer tasks at the same time. And the object "events" is a 
List<OpentsdbEvent>, it's not safe when multiple tasks consumer it. @gianm 
![qq20180829-125938](https://user-images.githubusercontent.com/5977839/44766326-909fdd80-ab8b-11e8-9961-c4b8a4ac4edb.jpg)
![qq20180829-130023](https://user-images.githubusercontent.com/5977839/44766328-909fdd80-ab8b-11e8-8e30-a8a0c4fb54ae.jpg)
![qq20180829-130037](https://user-images.githubusercontent.com/5977839/44766330-91387400-ab8b-11e8-8ab4-7b01ca990255.jpg)



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

Reply via email to