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

----


---

Reply via email to