storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bo...@apache.org
Subject [2/2] storm git commit: Merge branch 'STORM-2675' of https://github.com/srdo/storm into STORM-2675
Date Fri, 08 Sep 2017 14:25:16 GMT
Merge branch 'STORM-2675' of https://github.com/srdo/storm into STORM-2675

STORM-2675: Fix storm-kafka-client Trident spout failing to serialize
meta objects to Zookeeper

This closes #2271


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/ea0e465a
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/ea0e465a
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/ea0e465a

Branch: refs/heads/master
Commit: ea0e465ab863668f0b04aba7d01050aeb4b13d22
Parents: 306f399 54a829c
Author: Robert Evans <evans@yahoo-inc.com>
Authored: Fri Sep 8 08:56:38 2017 -0500
Committer: Robert Evans <evans@yahoo-inc.com>
Committed: Fri Sep 8 08:56:38 2017 -0500

----------------------------------------------------------------------
 examples/storm-kafka-client-examples/pom.xml    |  11 +-
 examples/storm-kafka-examples/pom.xml           |  11 +-
 external/storm-kafka-client/pom.xml             |   2 +-
 .../kafka/spout/subscription/Subscription.java  |   5 +-
 .../trident/KafkaTridentSpoutBatchMetadata.java |  77 +++++++++----
 .../spout/trident/KafkaTridentSpoutEmitter.java | 108 +++++++++++--------
 .../spout/trident/KafkaTridentSpoutManager.java |  10 +-
 .../spout/trident/KafkaTridentSpoutOpaque.java  |  12 +--
 .../KafkaTridentSpoutOpaqueCoordinator.java     |  17 +--
 .../spout/trident/TopicPartitionSerializer.java |  47 ++++++++
 .../storm/kafka/trident/TridentKafkaState.java  |   9 ++
 .../storm/kafka/spout/KafkaSpoutConfigTest.java |   2 +-
 .../SpoutWithMockedConsumerSetupHelper.java     |  33 ++++--
 .../KafkaTridentSpoutBatchMetadataTest.java     |  66 ++++++++++++
 .../spout/IOpaquePartitionedTridentSpout.java   |  22 +++-
 .../topology/state/TransactionalState.java      |  12 ++-
 16 files changed, 334 insertions(+), 110 deletions(-)
----------------------------------------------------------------------



Mime
View raw message