GitHub user srdo opened a pull request:
https://github.com/apache/storm/pull/2758
STORM-3046: Ensure KafkaTridentSpoutEmitter handles empty batches corâ¦
â¦rectly when they occur at the beginning of the stream
1.x version of https://github.com/apache/storm/pull/2652. The test is
missing because the file doesn't exist in 1.x, and the work to make the emitter
testable wasn't done on this branch.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/srdo/storm STORM-3046-1.x
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/storm/pull/2758.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 #2758
----
commit e63f5528bc2f807578560ec3f783f326e1aec2a0
Author: Stig Rohde Døssing <srdo@...>
Date: 2018-04-28T11:01:44Z
STORM-3046: Ensure KafkaTridentSpoutEmitter handles empty batches correctly
when they occur at the beginning of the stream
----
---