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 2016/05/16 23:29:48 UTC
[1/3] storm git commit: STORM-1725: Kafka Spout New Consumer API -
KafkaSpoutRetryExponentialBackoff method should use HashMap instead of
TreeMap not to throw Exception - Replace TreeMap with HashMap
Repository: storm
Updated Branches:
refs/heads/master 457a95f30 -> a9de15d40
STORM-1725: Kafka Spout New Consumer API - KafkaSpoutRetryExponentialBackoff method should use HashMap instead of TreeMap not to throw Exception
- Replace TreeMap with HashMap
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/3702df4a
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/3702df4a
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/3702df4a
Branch: refs/heads/master
Commit: 3702df4abfcad3537847f5aa957aaf243c1860a0
Parents: 27be83b
Author: Hugo Louro <hm...@gmail.com>
Authored: Fri Apr 22 10:16:31 2016 -0700
Committer: Hugo Louro <hm...@gmail.com>
Committed: Fri Apr 29 09:22:40 2016 -0700
----------------------------------------------------------------------
.../storm/kafka/spout/KafkaSpoutRetryExponentialBackoff.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/3702df4a/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutRetryExponentialBackoff.java
----------------------------------------------------------------------
diff --git a/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutRetryExponentialBackoff.java b/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutRetryExponentialBackoff.java
index 208cef4..78fd265 100644
--- a/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutRetryExponentialBackoff.java
+++ b/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutRetryExponentialBackoff.java
@@ -162,7 +162,7 @@ public class KafkaSpoutRetryExponentialBackoff implements KafkaSpoutRetryService
@Override
public Set<TopicPartition> retriableTopicPartitions() {
- final Set<TopicPartition> tps = new TreeSet<>();
+ final Set<TopicPartition> tps = new HashSet<>();
final long currentTimeNanos = System.nanoTime();
for (RetrySchedule retrySchedule : retrySchedules) {
if (retrySchedule.retry(currentTimeNanos)) {
[3/3] storm git commit: Added STORM-1725 to CHANGELOG 1.0.1 .
Posted by sr...@apache.org.
Added STORM-1725 to CHANGELOG 1.0.1 .
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/a9de15d4
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/a9de15d4
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/a9de15d4
Branch: refs/heads/master
Commit: a9de15d4060e8553b6841a6cd515d0b50f21a67c
Parents: 63a9c7b
Author: Sriharsha Chintalapani <ha...@hortonworks.com>
Authored: Mon May 16 16:28:10 2016 -0700
Committer: Sriharsha Chintalapani <ha...@hortonworks.com>
Committed: Mon May 16 16:28:10 2016 -0700
----------------------------------------------------------------------
CHANGELOG.md | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/a9de15d4/CHANGELOG.md
----------------------------------------------------------------------
diff --git a/CHANGELOG.md b/CHANGELOG.md
index f92ebfb..2a48c9f 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -101,6 +101,7 @@
* STORM-1773: Utils.javaDeserialize() doesn't work with primitive types
## 1.0.1
+ * STORM-1725: Kafka Spout New Consumer API - KafkaSpoutRetryExponentialBackoff method should use HashMap instead of TreeMap not to throw Exception
* STORM-1749: Fix storm-starter github links
* STORM-1678: abstract batch processing to common api `BatchHelper`
* STORM-1704: When logviewer_search.html opens daemon file, next search always show no result
[2/3] storm git commit: Merge branch 'master_STORM-1725' of
https://github.com/hmcl/storm-apache into STORM-1725
Posted by sr...@apache.org.
Merge branch 'master_STORM-1725' of https://github.com/hmcl/storm-apache into STORM-1725
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/63a9c7b6
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/63a9c7b6
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/63a9c7b6
Branch: refs/heads/master
Commit: 63a9c7b6ab4caa316473c5c5de4f13091edd7fb0
Parents: 457a95f 3702df4
Author: Sriharsha Chintalapani <ha...@hortonworks.com>
Authored: Mon May 16 16:26:42 2016 -0700
Committer: Sriharsha Chintalapani <ha...@hortonworks.com>
Committed: Mon May 16 16:26:42 2016 -0700
----------------------------------------------------------------------
.../storm/kafka/spout/KafkaSpoutRetryExponentialBackoff.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------