GitHub user hmcl opened a pull request:
https://github.com/apache/storm/pull/2438
STORM-2835: storm-kafka-client KafkaSpout can fail to remove all tuples
from waitingToEmit
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hmcl/storm-apache Apache_master_STORM-2385
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/storm/pull/2438.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #2438
----
commit e76d86a10cf6367acdaae1da071843ab8e83630e
Author: Hugo Louro <[email protected]>
Date: 2017-11-29T02:25:19Z
STORM-2835: storm-kafka-client KafkaSpout can fail to remove all tuples
from waitingToEmit
----
---