GitHub user hmcl opened a pull request:
https://github.com/apache/storm/pull/1902
STORM-2281: Running Multiple Kafka Spouts (Trident) Throws Illegal State
Exception
To review this PR please review only the commit that has STORM-2281. It is
currently sitting on top of the multiple commits addressing STORM-2225, waiting
for them to be squashed in and eventually merged.
@harshach can you please review. Thanks.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hmcl/storm-apache
1.x-branch_STORM-2225_KSSimpler_2
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/storm/pull/1902.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 #1902
----
commit 5e7d6a4fd7ed3fdd3400fc022c1df975381b51eb
Author: Robert (Bobby) Evans <[email protected]>
Date: 2017-01-23T21:11:22Z
Revert "Merge branch 'STORM-2236-1.x' of https://github.com/MediaV/storm
into STORM-2236-1.x-merge"
This reverts commit 389966ea4969d76271da1ad80f9f46e1c87cade4, reversing
changes made to 397977797a6ef940403c0ff4c14b834a45b6ae05.
commit 568d4b73e9b26e1f42350847798fc45639ba4de2
Author: Robert (Bobby) Evans <[email protected]>
Date: 2016-11-30T03:39:26Z
STORM-1997: copy state/bolt from storm-kafka to storm-kafka-client
STORM-2225: change spout config to be simpler.
STORM-2228: removed ability to request a single topic go to multiple streams
Conflicts:
examples/storm-kafka-client-examples/src/main/java/org/apache/storm/kafka/trident/TridentKafkaClientWordCountWildcardTopics.java
external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/builders/SingleTopicKafkaSpoutConfiguration.java
commit 389a02a266625683bfdb01f486b23ed2c98fe033
Author: Robert (Bobby) Evans <[email protected]>
Date: 2016-12-08T19:26:49Z
fixed some issues with rebase
Conflicts:
external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/KafkaSpoutRebalanceTest.java
commit 18f522fef2f64d6209c63db7b9e6426de8acc43d
Author: Robert (Bobby) Evans <[email protected]>
Date: 2016-12-08T22:10:12Z
addressed review comments
Conflicts:
external/storm-kafka-client/README.md
commit 4cf7f5595d7274b765ec84772a9fce388667748e
Author: Robert (Bobby) Evans <[email protected]>
Date: 2016-12-08T22:12:43Z
oops
commit f285060d92d93b23ed4a3721dfcbe9389c3c6c0c
Author: Robert (Bobby) Evans <[email protected]>
Date: 2017-01-06T22:37:31Z
STORM-2225: make the core API java7 compatible
commit 8fc59a46153efcafbce9f759b089d1eaca576079
Author: Robert (Bobby) Evans <[email protected]>
Date: 2017-01-06T22:42:31Z
STORM-2225: addressed doc review comments
commit 959f2ace453b0e421ad051654f8de93c21ee06a2
Author: Robert (Bobby) Evans <[email protected]>
Date: 2017-01-09T16:11:41Z
STORM-2225: java7 modifications
commit 390a39873cb8611e9f92615afaebd3a298204d8f
Author: Robert (Bobby) Evans <[email protected]>
Date: 2017-01-09T16:58:27Z
STORM-2225: Updated docs
commit a7387e1361a521cdb62ed6e5cd2a3833732704b6
Author: Robert (Bobby) Evans <[email protected]>
Date: 2017-01-09T17:06:12Z
Missed a Java 7 compatability issue
commit c4a3a4f1bb7ec7184e3927ca7b4c6592281218ad
Author: Robert (Bobby) Evans <[email protected]>
Date: 2017-01-09T17:15:38Z
STORM-2225: Fixed typo
commit 4483ffa60c37271b9c86f5b789cac8288885e0fb
Author: Robert (Bobby) Evans <[email protected]>
Date: 2017-01-17T16:07:13Z
STORM-2225: Addressed some review comments.
commit f82a0a3b407d03cd62c817f8473c770fc0bf0a68
Author: Robert (Bobby) Evans <[email protected]>
Date: 2017-01-17T18:39:43Z
STORM-2225: Make the config support Deserializer.class configs
commit f4df71a217482b25e44dd2d74ad50fa192f6d1df
Author: Robert (Bobby) Evans <[email protected]>
Date: 2017-01-18T16:32:06Z
STORM-2236: Reimplemented manual partition management on top of STORM-2225
commit 9952861c31b3c1524e9ff3631439ab0b0620dae0
Author: Robert (Bobby) Evans <[email protected]>
Date: 2017-01-18T17:08:46Z
STORM-2236: Make this work with trident and update the docs.
commit 34a98c4a735b835b1b67edebcc49940a178bbb8c
Author: Robert (Bobby) Evans <[email protected]>
Date: 2017-01-18T18:48:02Z
Addressed review comments
commit b57aee609fccb9fa1f7058c1f8091d05de9ddc8f
Author: Robert (Bobby) Evans <[email protected]>
Date: 2017-01-19T14:48:13Z
Fixed issue with upmerge
commit f6114715a950c9c79e97eb52e96c244731c293dd
Author: Robert (Bobby) Evans <[email protected]>
Date: 2017-01-19T18:32:05Z
STORM-2225: review rework
commit f0f00c2cedef5b09108a0fc73cde4de0abde0a12
Author: Robert (Bobby) Evans <[email protected]>
Date: 2017-01-19T20:59:39Z
Review comments
commit 094d6dcd8bdf1505e31c765675df3aeabfb4d694
Author: Robert (Bobby) Evans <[email protected]>
Date: 2017-01-23T16:42:23Z
Some final rework
commit 092b216071dbf82316679dfe0bc8d82cb5eeafbd
Author: Hugo Louro <[email protected]>
Date: 2017-01-30T08:02:42Z
STORM-2281: Running Multiple Kafka Spouts (Trident) Throws Illegal State
Exception
- Fix topic partition assignments to tasks running Kafka consumer
responsible for the assigned topic partitions
- Improved logging and code
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
