You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by sr...@apache.org on 2017/03/20 17:57:57 UTC
[2/3] storm git commit: Merge branch
'Apache_master_STORM-2407_KafkaTridentMissesData' of
https://github.com/hmcl/storm-apache
Merge branch 'Apache_master_STORM-2407_KafkaTridentMissesData' of https://github.com/hmcl/storm-apache
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/c2c9559f
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/c2c9559f
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/c2c9559f
Branch: refs/heads/master
Commit: c2c9559f0cac2049a83b026209610bd99dcf6a8e
Parents: f5a362a cd3b930
Author: Sriharsha Chintalapani <ha...@hortonworks.com>
Authored: Mon Mar 20 10:27:13 2017 -0700
Committer: Sriharsha Chintalapani <ha...@hortonworks.com>
Committed: Mon Mar 20 10:27:13 2017 -0700
----------------------------------------------------------------------
.../trident/OpaqueTridentEventHubEmitter.java | 7 +-
.../spout/trident/KafkaTridentSpoutEmitter.java | 94 +++++++-------------
.../spout/trident/KafkaTridentSpoutOpaque.java | 8 +-
.../kafka/trident/TridentKafkaEmitter.java | 7 +-
.../spout/IOpaquePartitionedTridentSpout.java | 29 +++++-
.../OpaquePartitionedTridentSpoutExecutor.java | 15 ++--
.../topology/state/TransactionalState.java | 4 +
7 files changed, 74 insertions(+), 90 deletions(-)
----------------------------------------------------------------------