Merge branch 'STORM-512' of https://github.com/nielsbasjes/storm into STORM-512
STORM-512: KafkaBolt doesn't handle ticks properly Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/25eb1418 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/25eb1418 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/25eb1418 Branch: refs/heads/master Commit: 25eb1418b87840b3b07e2045877fef7a0b2f28da Parents: 2aaa718 1ca5f76 Author: Robert (Bobby) Evans <[email protected]> Authored: Thu Apr 2 14:34:04 2015 -0500 Committer: Robert (Bobby) Evans <[email protected]> Committed: Thu Apr 2 14:34:04 2015 -0500 ---------------------------------------------------------------------- .../storm/starter/bolt/AbstractRankerBolt.java | 4 +-- .../storm/starter/bolt/RollingCountBolt.java | 4 +-- .../jvm/storm/starter/util/TupleHelpers.java | 33 ------------------ .../src/jvm/storm/kafka/bolt/KafkaBolt.java | 5 +++ .../jvm/backtype/storm/utils/TupleUtils.java | 35 ++++++++++++++++++++ .../trident/topology/TridentBoltExecutor.java | 3 +- 6 files changed, 46 insertions(+), 38 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/25eb1418/external/storm-kafka/src/jvm/storm/kafka/bolt/KafkaBolt.java ----------------------------------------------------------------------
