You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by ka...@apache.org on 2018/05/07 12:54:22 UTC
[2/2] storm git commit: Merge branch 'STORM-3059' of
https://github.com/srdo/storm into STORM-3059-merge
Merge branch 'STORM-3059' of https://github.com/srdo/storm into STORM-3059-merge
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/15a6fa57
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/15a6fa57
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/15a6fa57
Branch: refs/heads/master
Commit: 15a6fa5753d14ce5c12f054bf9255607e4943081
Parents: 02639f4 3370b2d
Author: Jungtaek Lim <ka...@gmail.com>
Authored: Mon May 7 21:53:05 2018 +0900
Committer: Jungtaek Lim <ka...@gmail.com>
Committed: Mon May 7 21:53:05 2018 +0900
----------------------------------------------------------------------
.../apache/storm/kafka/spout/KafkaSpout.java | 8 ++-
.../storm/kafka/NullRecordTranslator.java | 37 +++++++++++++
.../spout/KafkaSpoutMessagingGuaranteeTest.java | 58 +++++++++++++++-----
.../kafka/spout/KafkaSpoutNullTupleTest.java | 28 +---------
4 files changed, 89 insertions(+), 42 deletions(-)
----------------------------------------------------------------------