You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2014/06/19 23:06:12 UTC
[01/23] git commit: STORM-66 send taskid on initial handshake
Repository: incubator-storm
Updated Branches:
refs/heads/security 87cdbf5fd -> 79089ad0d
STORM-66 send taskid on initial handshake
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/47dba860
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/47dba860
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/47dba860
Branch: refs/heads/security
Commit: 47dba860094bbe381e0bd231a43e2501a98a855b
Parents: 254ec13
Author: David Losada <da...@tuxpiper.com>
Authored: Sun Feb 16 21:55:45 2014 +0100
Committer: David Losada <da...@tuxpiper.com>
Committed: Sun Feb 16 21:55:45 2014 +0100
----------------------------------------------------------------------
.../src/jvm/backtype/storm/task/TopologyContext.java | 11 +++++++++++
1 file changed, 11 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/47dba860/storm-core/src/jvm/backtype/storm/task/TopologyContext.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/task/TopologyContext.java b/storm-core/src/jvm/backtype/storm/task/TopologyContext.java
index c9df979..f540e90 100644
--- a/storm-core/src/jvm/backtype/storm/task/TopologyContext.java
+++ b/storm-core/src/jvm/backtype/storm/task/TopologyContext.java
@@ -37,6 +37,7 @@ import java.util.List;
import java.util.Map;
import java.util.Set;
import org.apache.commons.lang.NotImplementedException;
+import org.json.simple.JSONValue;
/**
* A TopologyContext is given to bolts and spouts in their "prepare" and "open"
@@ -217,6 +218,16 @@ public class TopologyContext extends WorkerTopologyContext implements IMetricsCo
public Collection<ITaskHook> getHooks() {
return _hooks;
}
+
+ @Override
+ public String toJSONString() {
+ Map obj = new HashMap();
+ obj.put("task->component", this.getTaskToComponent());
+ obj.put("taskid", this.getThisTaskId());
+ // TODO: jsonify StormTopology
+ // at the minimum should send source info
+ return JSONValue.toJSONString(obj);
+ }
/*
* Register a IMetric instance.
[19/23] git commit: STORM-352: fix logic for writing offsets to
ZooKeeper
Posted by bo...@apache.org.
STORM-352: fix logic for writing offsets to ZooKeeper
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/57851bb6
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/57851bb6
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/57851bb6
Branch: refs/heads/security
Commit: 57851bb6be4caec950541bcb1f01529224e52af4
Parents: d448e34
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Fri Jun 13 14:01:32 2014 -0400
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Fri Jun 13 14:13:50 2014 -0400
----------------------------------------------------------------------
external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/57851bb6/external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java
----------------------------------------------------------------------
diff --git a/external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java b/external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java
index d868e50..2c32a2c 100644
--- a/external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java
+++ b/external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java
@@ -214,7 +214,7 @@ public class PartitionManager {
public void commit() {
long lastCompletedOffset = lastCompletedOffset();
- if (lastCompletedOffset != lastCompletedOffset) {
+ if (_committedTo != lastCompletedOffset) {
LOG.debug("Writing last completed offset (" + lastCompletedOffset + ") to ZK for " + _partition + " for topology: " + _topologyInstanceId);
Map<Object, Object> data = (Map<Object, Object>) ImmutableMap.builder()
.put("topology", ImmutableMap.of("id", _topologyInstanceId,
[21/23] git commit: Merge branch 'STORM-352'
Posted by bo...@apache.org.
Merge branch 'STORM-352'
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/31a1592f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/31a1592f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/31a1592f
Branch: refs/heads/security
Commit: 31a1592f743d0efb5d393374d01e3eda9145cfff
Parents: 87a16c1 57851bb
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Fri Jun 13 15:12:24 2014 -0400
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Fri Jun 13 15:12:24 2014 -0400
----------------------------------------------------------------------
external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
[11/23] git commit: Merge branch 'master' of
https://git-wip-us.apache.org/repos/asf/incubator-storm
Posted by bo...@apache.org.
Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/incubator-storm
Conflicts:
CHANGELOG.md
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/61a4eac5
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/61a4eac5
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/61a4eac5
Branch: refs/heads/security
Commit: 61a4eac59e6af57ab9600663b537c120c91c30b6
Parents: b37b5c8 2bad66e
Author: Robert (Bobby) Evans <bo...@apache.org>
Authored: Thu Jun 12 16:44:09 2014 -0500
Committer: Robert (Bobby) Evans <bo...@apache.org>
Committed: Thu Jun 12 16:44:09 2014 -0500
----------------------------------------------------------------------
CHANGELOG.md | 2 +
examples/storm-starter/pom.xml | 2 +-
external/storm-kafka/pom.xml | 2 +-
pom.xml | 2 +-
.../maven-shade-clojure-transformer/pom.xml | 2 +-
storm-core/pom.xml | 9 +-
.../backtype/storm/utils/DisruptorQueue.java | 70 ++++++---
.../storm/utils/DisruptorQueueTest.java | 153 +++++++++++++++++++
storm-dist/binary/pom.xml | 2 +-
storm-dist/source/pom.xml | 2 +-
10 files changed, 218 insertions(+), 28 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/61a4eac5/CHANGELOG.md
----------------------------------------------------------------------
diff --cc CHANGELOG.md
index e636b46,2e5b079..8f73b83
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@@ -1,8 -1,6 +1,10 @@@
+## 0.9.3-incubating (unreleased)
+ * STORM-66: send taskid on initial handshake
+ * STORM-338: Move towards idiomatic Clojure style
+
## 0.9.2-incubating
+ * STORM-342: Contention in Disruptor Queue which may cause out of order or lost messages
+ * STORM-338: Move towards idiomatic Clojure style
* STORM-335: add drpc test for removing timed out requests from queue
* STORM-69: Storm UI Visualizations for Topologies
* STORM-297: Performance scaling with CPU
[18/23] git commit: [maven-release-plugin] prepare for next
development iteration
Posted by bo...@apache.org.
[maven-release-plugin] prepare for next development iteration
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/d448e348
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/d448e348
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/d448e348
Branch: refs/heads/security
Commit: d448e34812e5cbffe848ce88189a05df1be3226e
Parents: f037b41
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Thu Jun 12 20:52:30 2014 -0400
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Thu Jun 12 20:52:30 2014 -0400
----------------------------------------------------------------------
examples/storm-starter/pom.xml | 2 +-
external/storm-kafka/pom.xml | 2 +-
pom.xml | 4 ++--
storm-buildtools/maven-shade-clojure-transformer/pom.xml | 2 +-
storm-core/pom.xml | 2 +-
storm-dist/binary/pom.xml | 2 +-
storm-dist/source/pom.xml | 2 +-
7 files changed, 8 insertions(+), 8 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/d448e348/examples/storm-starter/pom.xml
----------------------------------------------------------------------
diff --git a/examples/storm-starter/pom.xml b/examples/storm-starter/pom.xml
index 0e0d920..903c6e7 100644
--- a/examples/storm-starter/pom.xml
+++ b/examples/storm-starter/pom.xml
@@ -20,7 +20,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.2-incubating</version>
+ <version>0.9.3-incubating-SNAPSHOT</version>
<relativePath>../../pom.xml</relativePath>
</parent>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/d448e348/external/storm-kafka/pom.xml
----------------------------------------------------------------------
diff --git a/external/storm-kafka/pom.xml b/external/storm-kafka/pom.xml
index a9d9a6d..4972619 100644
--- a/external/storm-kafka/pom.xml
+++ b/external/storm-kafka/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.2-incubating</version>
+ <version>0.9.3-incubating-SNAPSHOT</version>
<relativePath>../../pom.xml</relativePath>
</parent>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/d448e348/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index cba38e3..b7286dc 100644
--- a/pom.xml
+++ b/pom.xml
@@ -27,7 +27,7 @@
<groupId>org.apache.storm</groupId>
<artifactId>storm</artifactId>
- <version>0.9.2-incubating</version>
+ <version>0.9.3-incubating-SNAPSHOT</version>
<packaging>pom</packaging>
<name>Storm</name>
<description>Distributed and fault-tolerant realtime computation</description>
@@ -164,7 +164,7 @@
<scm>
<connection>scm:git:https://git-wip-us.apache.org/repos/asf/incubator-storm.git</connection>
<developerConnection>scm:git:https://git-wip-us.apache.org/repos/asf/incubator-storm.git</developerConnection>
- <tag>v0.9.2-incubating</tag>
+ <tag>HEAD</tag>
<url>https://git-wip-us.apache.org/repos/asf/incubator-storm</url>
</scm>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/d448e348/storm-buildtools/maven-shade-clojure-transformer/pom.xml
----------------------------------------------------------------------
diff --git a/storm-buildtools/maven-shade-clojure-transformer/pom.xml b/storm-buildtools/maven-shade-clojure-transformer/pom.xml
index 27d0cfe..a6fbad1 100644
--- a/storm-buildtools/maven-shade-clojure-transformer/pom.xml
+++ b/storm-buildtools/maven-shade-clojure-transformer/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.2-incubating</version>
+ <version>0.9.3-incubating-SNAPSHOT</version>
<relativePath>../../pom.xml</relativePath>
</parent>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/d448e348/storm-core/pom.xml
----------------------------------------------------------------------
diff --git a/storm-core/pom.xml b/storm-core/pom.xml
index 34118fe..45878f6 100644
--- a/storm-core/pom.xml
+++ b/storm-core/pom.xml
@@ -20,7 +20,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.2-incubating</version>
+ <version>0.9.3-incubating-SNAPSHOT</version>
</parent>
<groupId>org.apache.storm</groupId>
<artifactId>storm-core</artifactId>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/d448e348/storm-dist/binary/pom.xml
----------------------------------------------------------------------
diff --git a/storm-dist/binary/pom.xml b/storm-dist/binary/pom.xml
index 6ffe62d..0d97c0b 100644
--- a/storm-dist/binary/pom.xml
+++ b/storm-dist/binary/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.2-incubating</version>
+ <version>0.9.3-incubating-SNAPSHOT</version>
<relativePath>../../pom.xml</relativePath>
</parent>
<groupId>org.apache.storm</groupId>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/d448e348/storm-dist/source/pom.xml
----------------------------------------------------------------------
diff --git a/storm-dist/source/pom.xml b/storm-dist/source/pom.xml
index 2bd815b..4fedefb 100644
--- a/storm-dist/source/pom.xml
+++ b/storm-dist/source/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.2-incubating</version>
+ <version>0.9.3-incubating-SNAPSHOT</version>
<relativePath>../../pom.xml</relativePath>
</parent>
<groupId>org.apache.storm</groupId>
[16/23] git commit: merge CHANGELOG.md for 0.9.2-incubating re-release
Posted by bo...@apache.org.
merge CHANGELOG.md for 0.9.2-incubating re-release
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/18b3db97
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/18b3db97
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/18b3db97
Branch: refs/heads/security
Commit: 18b3db976c0f5d9e1b66ef468de83cbff7959c39
Parents: 4650914
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Thu Jun 12 20:47:16 2014 -0400
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Thu Jun 12 20:47:16 2014 -0400
----------------------------------------------------------------------
CHANGELOG.md | 5 +----
1 file changed, 1 insertion(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/18b3db97/CHANGELOG.md
----------------------------------------------------------------------
diff --git a/CHANGELOG.md b/CHANGELOG.md
index 8f73b83..95024da 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,8 +1,5 @@
-## 0.9.3-incubating (unreleased)
- * STORM-66: send taskid on initial handshake
- * STORM-338: Move towards idiomatic Clojure style
-
## 0.9.2-incubating
+ * STORM-66: send taskid on initial handshake
* STORM-342: Contention in Disruptor Queue which may cause out of order or lost messages
* STORM-338: Move towards idiomatic Clojure style
* STORM-335: add drpc test for removing timed out requests from queue
[13/23] git commit: Merge branch 'master' of
https://git-wip-us.apache.org/repos/asf/incubator-storm
Posted by bo...@apache.org.
Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/incubator-storm
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/09e50c10
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/09e50c10
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/09e50c10
Branch: refs/heads/security
Commit: 09e50c10aa08fef6f6a1a803d636b8b1e4c690c1
Parents: 12f79bb 61a4eac
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Thu Jun 12 20:44:11 2014 -0400
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Thu Jun 12 20:44:11 2014 -0400
----------------------------------------------------------------------
CHANGELOG.md | 4 ++++
.../src/jvm/backtype/storm/task/TopologyContext.java | 11 +++++++++++
2 files changed, 15 insertions(+)
----------------------------------------------------------------------
[08/23] git commit: revert poms for 0.9.2-incubating re-release
Posted by bo...@apache.org.
revert poms for 0.9.2-incubating re-release
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/2bad66ea
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/2bad66ea
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/2bad66ea
Branch: refs/heads/security
Commit: 2bad66eae90651df7424b389f099e62fe8b9ec5f
Parents: 5299531
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Thu Jun 12 17:02:36 2014 -0400
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Thu Jun 12 17:02:36 2014 -0400
----------------------------------------------------------------------
examples/storm-starter/pom.xml | 2 +-
external/storm-kafka/pom.xml | 2 +-
pom.xml | 2 +-
storm-buildtools/maven-shade-clojure-transformer/pom.xml | 2 +-
storm-core/pom.xml | 2 +-
storm-dist/binary/pom.xml | 2 +-
storm-dist/source/pom.xml | 2 +-
7 files changed, 7 insertions(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/2bad66ea/examples/storm-starter/pom.xml
----------------------------------------------------------------------
diff --git a/examples/storm-starter/pom.xml b/examples/storm-starter/pom.xml
index 903c6e7..182546f 100644
--- a/examples/storm-starter/pom.xml
+++ b/examples/storm-starter/pom.xml
@@ -20,7 +20,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.3-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating-SNAPSHOT</version>
<relativePath>../../pom.xml</relativePath>
</parent>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/2bad66ea/external/storm-kafka/pom.xml
----------------------------------------------------------------------
diff --git a/external/storm-kafka/pom.xml b/external/storm-kafka/pom.xml
index 4972619..ff411a3 100644
--- a/external/storm-kafka/pom.xml
+++ b/external/storm-kafka/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.3-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating-SNAPSHOT</version>
<relativePath>../../pom.xml</relativePath>
</parent>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/2bad66ea/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index b7286dc..ce10cc2 100644
--- a/pom.xml
+++ b/pom.xml
@@ -27,7 +27,7 @@
<groupId>org.apache.storm</groupId>
<artifactId>storm</artifactId>
- <version>0.9.3-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating-SNAPSHOT</version>
<packaging>pom</packaging>
<name>Storm</name>
<description>Distributed and fault-tolerant realtime computation</description>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/2bad66ea/storm-buildtools/maven-shade-clojure-transformer/pom.xml
----------------------------------------------------------------------
diff --git a/storm-buildtools/maven-shade-clojure-transformer/pom.xml b/storm-buildtools/maven-shade-clojure-transformer/pom.xml
index a6fbad1..7dfa2a2 100644
--- a/storm-buildtools/maven-shade-clojure-transformer/pom.xml
+++ b/storm-buildtools/maven-shade-clojure-transformer/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.3-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating-SNAPSHOT</version>
<relativePath>../../pom.xml</relativePath>
</parent>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/2bad66ea/storm-core/pom.xml
----------------------------------------------------------------------
diff --git a/storm-core/pom.xml b/storm-core/pom.xml
index 45878f6..26f08cb 100644
--- a/storm-core/pom.xml
+++ b/storm-core/pom.xml
@@ -20,7 +20,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.3-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating-SNAPSHOT</version>
</parent>
<groupId>org.apache.storm</groupId>
<artifactId>storm-core</artifactId>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/2bad66ea/storm-dist/binary/pom.xml
----------------------------------------------------------------------
diff --git a/storm-dist/binary/pom.xml b/storm-dist/binary/pom.xml
index 0d97c0b..4fa3a27 100644
--- a/storm-dist/binary/pom.xml
+++ b/storm-dist/binary/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.3-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating-SNAPSHOT</version>
<relativePath>../../pom.xml</relativePath>
</parent>
<groupId>org.apache.storm</groupId>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/2bad66ea/storm-dist/source/pom.xml
----------------------------------------------------------------------
diff --git a/storm-dist/source/pom.xml b/storm-dist/source/pom.xml
index 4fedefb..b5552df 100644
--- a/storm-dist/source/pom.xml
+++ b/storm-dist/source/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.3-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating-SNAPSHOT</version>
<relativePath>../../pom.xml</relativePath>
</parent>
<groupId>org.apache.storm</groupId>
[02/23] git commit: STORM-342: Message loss, executor hang,
or message disorder due to contention in Disruptor queue under
multi-thread mode.
Posted by bo...@apache.org.
STORM-342: Message loss, executor hang, or message disorder due to contention in Disruptor queue under multi-thread mode.
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/72b1f592
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/72b1f592
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/72b1f592
Branch: refs/heads/security
Commit: 72b1f592885abc8c02c6902aa0eb6499bacae7f2
Parents: c89fb82
Author: Sean Zhong <cl...@gmail.com>
Authored: Tue Jun 10 19:54:11 2014 +0800
Committer: Sean Zhong <cl...@gmail.com>
Committed: Tue Jun 10 19:54:11 2014 +0800
----------------------------------------------------------------------
storm-core/pom.xml | 7 +
.../backtype/storm/utils/DisruptorQueue.java | 70 ++++++---
.../storm/utils/DisruptorQueueTest.java | 154 +++++++++++++++++++
3 files changed, 210 insertions(+), 21 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/72b1f592/storm-core/pom.xml
----------------------------------------------------------------------
diff --git a/storm-core/pom.xml b/storm-core/pom.xml
index fec6218..26f08cb 100644
--- a/storm-core/pom.xml
+++ b/storm-core/pom.xml
@@ -176,9 +176,16 @@
<artifactId>conjure</artifactId>
<scope>test</scope>
</dependency>
+ <dependency>
+ <groupId>junit</groupId>
+ <artifactId>junit</artifactId>
+ <version>4.1</version>
+ <scope>test</scope>
+ </dependency>
</dependencies>
<build>
<sourceDirectory>src/jvm</sourceDirectory>
+ <testSourceDirectory>test/jvm</testSourceDirectory>
<resources>
<resource>
<directory>../conf</directory>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/72b1f592/storm-core/src/jvm/backtype/storm/utils/DisruptorQueue.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/utils/DisruptorQueue.java b/storm-core/src/jvm/backtype/storm/utils/DisruptorQueue.java
index 8c5b466..0068964 100644
--- a/storm-core/src/jvm/backtype/storm/utils/DisruptorQueue.java
+++ b/storm-core/src/jvm/backtype/storm/utils/DisruptorQueue.java
@@ -27,13 +27,15 @@ import com.lmax.disruptor.Sequence;
import com.lmax.disruptor.SequenceBarrier;
import com.lmax.disruptor.SingleThreadedClaimStrategy;
import com.lmax.disruptor.WaitStrategy;
+
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.TimeUnit;
+import java.util.concurrent.locks.Lock;
+import java.util.concurrent.locks.ReentrantReadWriteLock;
import java.util.HashMap;
import java.util.Map;
import backtype.storm.metric.api.IStatefulObject;
-import java.util.logging.Level;
-import java.util.logging.Logger;
+
/**
*
@@ -51,6 +53,11 @@ public class DisruptorQueue implements IStatefulObject {
// TODO: consider having a threadlocal cache of this variable to speed up reads?
volatile boolean consumerStartedFlag = false;
ConcurrentLinkedQueue<Object> _cache = new ConcurrentLinkedQueue();
+
+ private final ReentrantReadWriteLock cacheLock = new ReentrantReadWriteLock();
+ private final Lock cacheReadLock = cacheLock.readLock();
+ private final Lock cacheWriteLock = cacheLock.writeLock();
+
private static String PREFIX = "disruptor-";
private String _queueName = "";
@@ -62,6 +69,13 @@ public class DisruptorQueue implements IStatefulObject {
_buffer.setGatingSequences(_consumer);
if(claim instanceof SingleThreadedClaimStrategy) {
consumerStartedFlag = true;
+ } else {
+ // make sure we flush the pending messages in cache first
+ try {
+ publishDirect(FLUSH_CACHE, true);
+ } catch (InsufficientCapacityException e) {
+ throw new RuntimeException("This code should be unreachable!");
+ }
}
}
@@ -134,33 +148,47 @@ public class DisruptorQueue implements IStatefulObject {
}
public void publish(Object obj, boolean block) throws InsufficientCapacityException {
- if(consumerStartedFlag) {
- final long id;
- if(block) {
- id = _buffer.next();
- } else {
- id = _buffer.tryNext(1);
+
+ boolean publishNow = consumerStartedFlag;
+
+ if (!publishNow) {
+ cacheReadLock.lock();
+ try {
+ publishNow = consumerStartedFlag;
+ if (!publishNow) {
+ _cache.add(obj);
+ }
+ } finally {
+ cacheReadLock.unlock();
}
- final MutableObject m = _buffer.get(id);
- m.setObject(obj);
- _buffer.publish(id);
- } else {
- _cache.add(obj);
- if(consumerStartedFlag) flushCache();
+ }
+
+ if (publishNow) {
+ publishDirect(obj, block);
}
}
- public void consumerStarted() {
- if(!consumerStartedFlag) {
- consumerStartedFlag = true;
- flushCache();
+ private void publishDirect(Object obj, boolean block) throws InsufficientCapacityException {
+ final long id;
+ if(block) {
+ id = _buffer.next();
+ } else {
+ id = _buffer.tryNext(1);
}
+ final MutableObject m = _buffer.get(id);
+ m.setObject(obj);
+ _buffer.publish(id);
}
- private void flushCache() {
- publish(FLUSH_CACHE);
- }
+ public void consumerStarted() {
+ consumerStartedFlag = true;
+
+ // Use writeLock to make sure all pending cache add opearation completed
+ cacheWriteLock.lock();
+ cacheWriteLock.unlock();
+ }
+
public long population() { return (writePos() - readPos()); }
public long capacity() { return _buffer.getBufferSize(); }
public long writePos() { return _buffer.getCursor(); }
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/72b1f592/storm-core/test/jvm/backtype/storm/utils/DisruptorQueueTest.java
----------------------------------------------------------------------
diff --git a/storm-core/test/jvm/backtype/storm/utils/DisruptorQueueTest.java b/storm-core/test/jvm/backtype/storm/utils/DisruptorQueueTest.java
new file mode 100644
index 0000000..f21b10f
--- /dev/null
+++ b/storm-core/test/jvm/backtype/storm/utils/DisruptorQueueTest.java
@@ -0,0 +1,154 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package backtype.storm.utils;
+
+import java.util.concurrent.atomic.AtomicBoolean;
+
+import com.lmax.disruptor.BlockingWaitStrategy;
+import com.lmax.disruptor.EventHandler;
+import com.lmax.disruptor.InsufficientCapacityException;
+import com.lmax.disruptor.MultiThreadedClaimStrategy;
+import org.junit.Assert;
+import org.junit.Test;
+import junit.framework.TestCase;
+
+public class DisruptorQueueTest extends TestCase {
+
+ private final static int TIMEOUT = 5; // MS
+ private final static int PRODUCER_NUM = 4;
+
+ @Test
+ public void testMessageDisorder() throws InterruptedException {
+
+ // Set queue length to bigger enough
+ DisruptorQueue queue = createQueue("messageOrder", 16);
+
+ queue.publish("1");
+
+ Runnable producer = new Producer(queue, "2");
+
+ final Object [] result = new Object[1];
+ Runnable consumer = new Consumer(queue, new EventHandler<Object>() {
+ private boolean head = true;
+
+ @Override
+ public void onEvent(Object obj, long sequence, boolean endOfBatch)
+ throws Exception {
+ if (head) {
+ head = false;
+ result[0] = obj;
+ }
+ }
+ });
+
+ Assert.assertEquals("We expect to receive first published message first, but received " + result[0].toString(),
+ "1", result[0]);
+ run(producer, consumer);
+ }
+
+ @Test
+ public void testConsumerHang() throws InterruptedException {
+ final AtomicBoolean messageConsumed = new AtomicBoolean(false);
+
+ // Set queue length to 1, so that the RingBuffer can be easily full
+ // to trigger consumer blocking
+ DisruptorQueue queue = createQueue("consumerHang", 1);
+ Runnable producer = new Producer(queue, "msg");
+ Runnable consumer = new Consumer(queue, new EventHandler<Object>() {
+ @Override
+ public void onEvent(Object obj, long sequence, boolean endOfBatch)
+ throws Exception {
+ messageConsumed.set(true);
+ }
+ });
+
+ run(producer, consumer);
+ Assert.assertTrue("disruptor message is never consumed due to consumer thread hangs",
+ messageConsumed.get());
+ }
+
+
+ private void run(Runnable producer, Runnable consumer)
+ throws InterruptedException {
+
+ Thread[] producerThreads = new Thread[PRODUCER_NUM];
+ for (int i = 0; i < PRODUCER_NUM; i++) {
+ producerThreads[i] = new Thread(producer);
+ producerThreads[i].start();
+ }
+
+ Thread consumerThread = new Thread(consumer);
+ consumerThread.start();
+
+ for (int i = 0; i < PRODUCER_NUM; i++) {
+ producerThreads[i].interrupt();
+ producerThreads[i].join(TIMEOUT);
+ }
+ consumerThread.interrupt();
+ consumerThread.join(TIMEOUT);
+ //consumerThread.stop();
+ }
+
+ private class Producer implements Runnable {
+ private String msg;
+ private DisruptorQueue queue;
+
+ Producer(DisruptorQueue queue, String msg) {
+ this.msg = msg;
+ this.queue = queue;
+ }
+
+ @Override
+ public void run() {
+ try {
+ while (true) {
+ queue.publish(msg, false);
+ }
+ } catch (InsufficientCapacityException e) {
+ return;
+ }
+ }
+ };
+
+ private class Consumer implements Runnable {
+ private EventHandler handler;
+ private DisruptorQueue queue;
+
+ Consumer(DisruptorQueue queue, EventHandler handler) {
+ this.handler = handler;
+ this.queue = queue;
+ }
+
+ @Override
+ public void run() {
+ queue.consumerStarted();
+ try {
+ while(true) {
+ queue.consumeBatchWhenAvailable(handler);
+ }
+ }catch(RuntimeException e) {
+ //break
+ }
+ }
+ };
+
+ private static DisruptorQueue createQueue(String name, int queueSize) {
+ return new DisruptorQueue(name, new MultiThreadedClaimStrategy(
+ queueSize), new BlockingWaitStrategy());
+ }
+}
[03/23] git commit: STORM-342: rename the read-write lock
Posted by bo...@apache.org.
STORM-342: rename the read-write lock
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/6946c34e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/6946c34e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/6946c34e
Branch: refs/heads/security
Commit: 6946c34e9f06726b46c5fb1bf12e1f186a1a8a19
Parents: 72b1f59
Author: Sean Zhong <cl...@gmail.com>
Authored: Tue Jun 10 20:29:28 2014 +0800
Committer: Sean Zhong <cl...@gmail.com>
Committed: Tue Jun 10 20:29:28 2014 +0800
----------------------------------------------------------------------
.../src/jvm/backtype/storm/utils/DisruptorQueue.java | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/6946c34e/storm-core/src/jvm/backtype/storm/utils/DisruptorQueue.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/utils/DisruptorQueue.java b/storm-core/src/jvm/backtype/storm/utils/DisruptorQueue.java
index 0068964..75ccbbc 100644
--- a/storm-core/src/jvm/backtype/storm/utils/DisruptorQueue.java
+++ b/storm-core/src/jvm/backtype/storm/utils/DisruptorQueue.java
@@ -55,8 +55,8 @@ public class DisruptorQueue implements IStatefulObject {
ConcurrentLinkedQueue<Object> _cache = new ConcurrentLinkedQueue();
private final ReentrantReadWriteLock cacheLock = new ReentrantReadWriteLock();
- private final Lock cacheReadLock = cacheLock.readLock();
- private final Lock cacheWriteLock = cacheLock.writeLock();
+ private final Lock readLock = cacheLock.readLock();
+ private final Lock writeLock = cacheLock.writeLock();
private static String PREFIX = "disruptor-";
private String _queueName = "";
@@ -152,14 +152,14 @@ public class DisruptorQueue implements IStatefulObject {
boolean publishNow = consumerStartedFlag;
if (!publishNow) {
- cacheReadLock.lock();
+ readLock.lock();
try {
publishNow = consumerStartedFlag;
if (!publishNow) {
_cache.add(obj);
}
} finally {
- cacheReadLock.unlock();
+ readLock.unlock();
}
}
@@ -185,8 +185,8 @@ public class DisruptorQueue implements IStatefulObject {
consumerStartedFlag = true;
// Use writeLock to make sure all pending cache add opearation completed
- cacheWriteLock.lock();
- cacheWriteLock.unlock();
+ writeLock.lock();
+ writeLock.unlock();
}
public long population() { return (writePos() - readPos()); }
[04/23] git commit: STORM-342: add exception as cause when re-thrown
Posted by bo...@apache.org.
STORM-342: add exception as cause when re-thrown
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/8b57097c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/8b57097c
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/8b57097c
Branch: refs/heads/security
Commit: 8b57097c6dc39f267bcbafb671ac977872380a8f
Parents: 6946c34
Author: Sean Zhong <cl...@gmail.com>
Authored: Thu Jun 12 08:53:17 2014 +0800
Committer: Sean Zhong <cl...@gmail.com>
Committed: Thu Jun 12 08:53:17 2014 +0800
----------------------------------------------------------------------
storm-core/src/jvm/backtype/storm/utils/DisruptorQueue.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/8b57097c/storm-core/src/jvm/backtype/storm/utils/DisruptorQueue.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/utils/DisruptorQueue.java b/storm-core/src/jvm/backtype/storm/utils/DisruptorQueue.java
index 75ccbbc..932af16 100644
--- a/storm-core/src/jvm/backtype/storm/utils/DisruptorQueue.java
+++ b/storm-core/src/jvm/backtype/storm/utils/DisruptorQueue.java
@@ -74,7 +74,7 @@ public class DisruptorQueue implements IStatefulObject {
try {
publishDirect(FLUSH_CACHE, true);
} catch (InsufficientCapacityException e) {
- throw new RuntimeException("This code should be unreachable!");
+ throw new RuntimeException("This code should be unreachable!", e);
}
}
}
[05/23] git commit: Merge branch
'disruptor_message_loss_hang_or_disorder' of
github.com:clockfly/incubator-storm
Posted by bo...@apache.org.
Merge branch 'disruptor_message_loss_hang_or_disorder' of github.com:clockfly/incubator-storm
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/f1bf9cdb
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/f1bf9cdb
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/f1bf9cdb
Branch: refs/heads/security
Commit: f1bf9cdb5c7fd7445948f7f3097dbe8ced27d3c0
Parents: 0826b93 8b57097
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Thu Jun 12 16:37:15 2014 -0400
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Thu Jun 12 16:37:15 2014 -0400
----------------------------------------------------------------------
storm-core/pom.xml | 7 +
.../backtype/storm/utils/DisruptorQueue.java | 70 ++++++---
.../storm/utils/DisruptorQueueTest.java | 154 +++++++++++++++++++
3 files changed, 210 insertions(+), 21 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/f1bf9cdb/storm-core/pom.xml
----------------------------------------------------------------------
[12/23] git commit: [maven-release-plugin] prepare release
v0.9.2-incubating
Posted by bo...@apache.org.
[maven-release-plugin] prepare release v0.9.2-incubating
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/12f79bb1
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/12f79bb1
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/12f79bb1
Branch: refs/heads/security
Commit: 12f79bb1c51f84f29a18d3a80bc5d59cd498df35
Parents: 2bad66e
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Thu Jun 12 20:08:48 2014 -0400
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Thu Jun 12 20:08:48 2014 -0400
----------------------------------------------------------------------
examples/storm-starter/pom.xml | 2 +-
external/storm-kafka/pom.xml | 2 +-
pom.xml | 4 ++--
storm-buildtools/maven-shade-clojure-transformer/pom.xml | 2 +-
storm-core/pom.xml | 2 +-
storm-dist/binary/pom.xml | 2 +-
storm-dist/source/pom.xml | 2 +-
7 files changed, 8 insertions(+), 8 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/12f79bb1/examples/storm-starter/pom.xml
----------------------------------------------------------------------
diff --git a/examples/storm-starter/pom.xml b/examples/storm-starter/pom.xml
index 182546f..0e0d920 100644
--- a/examples/storm-starter/pom.xml
+++ b/examples/storm-starter/pom.xml
@@ -20,7 +20,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.2-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating</version>
<relativePath>../../pom.xml</relativePath>
</parent>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/12f79bb1/external/storm-kafka/pom.xml
----------------------------------------------------------------------
diff --git a/external/storm-kafka/pom.xml b/external/storm-kafka/pom.xml
index ff411a3..a9d9a6d 100644
--- a/external/storm-kafka/pom.xml
+++ b/external/storm-kafka/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.2-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating</version>
<relativePath>../../pom.xml</relativePath>
</parent>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/12f79bb1/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index ce10cc2..cba38e3 100644
--- a/pom.xml
+++ b/pom.xml
@@ -27,7 +27,7 @@
<groupId>org.apache.storm</groupId>
<artifactId>storm</artifactId>
- <version>0.9.2-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating</version>
<packaging>pom</packaging>
<name>Storm</name>
<description>Distributed and fault-tolerant realtime computation</description>
@@ -164,7 +164,7 @@
<scm>
<connection>scm:git:https://git-wip-us.apache.org/repos/asf/incubator-storm.git</connection>
<developerConnection>scm:git:https://git-wip-us.apache.org/repos/asf/incubator-storm.git</developerConnection>
- <tag>HEAD</tag>
+ <tag>v0.9.2-incubating</tag>
<url>https://git-wip-us.apache.org/repos/asf/incubator-storm</url>
</scm>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/12f79bb1/storm-buildtools/maven-shade-clojure-transformer/pom.xml
----------------------------------------------------------------------
diff --git a/storm-buildtools/maven-shade-clojure-transformer/pom.xml b/storm-buildtools/maven-shade-clojure-transformer/pom.xml
index 7dfa2a2..27d0cfe 100644
--- a/storm-buildtools/maven-shade-clojure-transformer/pom.xml
+++ b/storm-buildtools/maven-shade-clojure-transformer/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.2-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating</version>
<relativePath>../../pom.xml</relativePath>
</parent>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/12f79bb1/storm-core/pom.xml
----------------------------------------------------------------------
diff --git a/storm-core/pom.xml b/storm-core/pom.xml
index 26f08cb..34118fe 100644
--- a/storm-core/pom.xml
+++ b/storm-core/pom.xml
@@ -20,7 +20,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.2-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating</version>
</parent>
<groupId>org.apache.storm</groupId>
<artifactId>storm-core</artifactId>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/12f79bb1/storm-dist/binary/pom.xml
----------------------------------------------------------------------
diff --git a/storm-dist/binary/pom.xml b/storm-dist/binary/pom.xml
index 4fa3a27..6ffe62d 100644
--- a/storm-dist/binary/pom.xml
+++ b/storm-dist/binary/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.2-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating</version>
<relativePath>../../pom.xml</relativePath>
</parent>
<groupId>org.apache.storm</groupId>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/12f79bb1/storm-dist/source/pom.xml
----------------------------------------------------------------------
diff --git a/storm-dist/source/pom.xml b/storm-dist/source/pom.xml
index b5552df..2bd815b 100644
--- a/storm-dist/source/pom.xml
+++ b/storm-dist/source/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.2-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating</version>
<relativePath>../../pom.xml</relativePath>
</parent>
<groupId>org.apache.storm</groupId>
[10/23] git commit: added STORM-66 to Changelog.
Posted by bo...@apache.org.
added STORM-66 to Changelog.
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/b37b5c82
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/b37b5c82
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/b37b5c82
Branch: refs/heads/security
Commit: b37b5c82ed6fd6a43c701e75260f5cdf343f5f43
Parents: 00cc9c6
Author: Robert (Bobby) Evans <bo...@apache.org>
Authored: Thu Jun 12 16:42:50 2014 -0500
Committer: Robert (Bobby) Evans <bo...@apache.org>
Committed: Thu Jun 12 16:42:50 2014 -0500
----------------------------------------------------------------------
CHANGELOG.md | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/b37b5c82/CHANGELOG.md
----------------------------------------------------------------------
diff --git a/CHANGELOG.md b/CHANGELOG.md
index ee2eae5..e636b46 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,4 +1,5 @@
## 0.9.3-incubating (unreleased)
+ * STORM-66: send taskid on initial handshake
* STORM-338: Move towards idiomatic Clojure style
## 0.9.2-incubating
[07/23] git commit: update changelog for STORM-342
Posted by bo...@apache.org.
update changelog for STORM-342
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/52995317
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/52995317
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/52995317
Branch: refs/heads/security
Commit: 5299531739b6661a7ce8d3aafb486d6dde09bbf6
Parents: 405dabb
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Thu Jun 12 17:00:30 2014 -0400
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Thu Jun 12 17:00:30 2014 -0400
----------------------------------------------------------------------
CHANGELOG.md | 5 ++---
.../test/jvm/backtype/storm/utils/DisruptorQueueTest.java | 1 -
2 files changed, 2 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/52995317/CHANGELOG.md
----------------------------------------------------------------------
diff --git a/CHANGELOG.md b/CHANGELOG.md
index ee2eae5..2e5b079 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,7 +1,6 @@
-## 0.9.3-incubating (unreleased)
- * STORM-338: Move towards idiomatic Clojure style
-
## 0.9.2-incubating
+ * STORM-342: Contention in Disruptor Queue which may cause out of order or lost messages
+ * STORM-338: Move towards idiomatic Clojure style
* STORM-335: add drpc test for removing timed out requests from queue
* STORM-69: Storm UI Visualizations for Topologies
* STORM-297: Performance scaling with CPU
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/52995317/storm-core/test/jvm/backtype/storm/utils/DisruptorQueueTest.java
----------------------------------------------------------------------
diff --git a/storm-core/test/jvm/backtype/storm/utils/DisruptorQueueTest.java b/storm-core/test/jvm/backtype/storm/utils/DisruptorQueueTest.java
index 747d95c..653fd33 100644
--- a/storm-core/test/jvm/backtype/storm/utils/DisruptorQueueTest.java
+++ b/storm-core/test/jvm/backtype/storm/utils/DisruptorQueueTest.java
@@ -101,7 +101,6 @@ public class DisruptorQueueTest extends TestCase {
}
consumerThread.interrupt();
consumerThread.join(TIMEOUT);
- //consumerThread.stop();
}
private class Producer implements Runnable {
[22/23] git commit: [maven-release-plugin] prepare release
v0.9.2-incubating
Posted by bo...@apache.org.
[maven-release-plugin] prepare release v0.9.2-incubating
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/24d4a14d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/24d4a14d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/24d4a14d
Branch: refs/heads/security
Commit: 24d4a14de310cbbfebdc4a50d8cc9d86f9943087
Parents: 31a1592
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Fri Jun 13 16:21:51 2014 -0400
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Fri Jun 13 16:21:51 2014 -0400
----------------------------------------------------------------------
examples/storm-starter/pom.xml | 2 +-
external/storm-kafka/pom.xml | 2 +-
pom.xml | 4 ++--
storm-buildtools/maven-shade-clojure-transformer/pom.xml | 2 +-
storm-core/pom.xml | 2 +-
storm-dist/binary/pom.xml | 2 +-
storm-dist/source/pom.xml | 2 +-
7 files changed, 8 insertions(+), 8 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/24d4a14d/examples/storm-starter/pom.xml
----------------------------------------------------------------------
diff --git a/examples/storm-starter/pom.xml b/examples/storm-starter/pom.xml
index 182546f..0e0d920 100644
--- a/examples/storm-starter/pom.xml
+++ b/examples/storm-starter/pom.xml
@@ -20,7 +20,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.2-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating</version>
<relativePath>../../pom.xml</relativePath>
</parent>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/24d4a14d/external/storm-kafka/pom.xml
----------------------------------------------------------------------
diff --git a/external/storm-kafka/pom.xml b/external/storm-kafka/pom.xml
index ff411a3..a9d9a6d 100644
--- a/external/storm-kafka/pom.xml
+++ b/external/storm-kafka/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.2-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating</version>
<relativePath>../../pom.xml</relativePath>
</parent>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/24d4a14d/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index ce10cc2..cba38e3 100644
--- a/pom.xml
+++ b/pom.xml
@@ -27,7 +27,7 @@
<groupId>org.apache.storm</groupId>
<artifactId>storm</artifactId>
- <version>0.9.2-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating</version>
<packaging>pom</packaging>
<name>Storm</name>
<description>Distributed and fault-tolerant realtime computation</description>
@@ -164,7 +164,7 @@
<scm>
<connection>scm:git:https://git-wip-us.apache.org/repos/asf/incubator-storm.git</connection>
<developerConnection>scm:git:https://git-wip-us.apache.org/repos/asf/incubator-storm.git</developerConnection>
- <tag>HEAD</tag>
+ <tag>v0.9.2-incubating</tag>
<url>https://git-wip-us.apache.org/repos/asf/incubator-storm</url>
</scm>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/24d4a14d/storm-buildtools/maven-shade-clojure-transformer/pom.xml
----------------------------------------------------------------------
diff --git a/storm-buildtools/maven-shade-clojure-transformer/pom.xml b/storm-buildtools/maven-shade-clojure-transformer/pom.xml
index 7dfa2a2..27d0cfe 100644
--- a/storm-buildtools/maven-shade-clojure-transformer/pom.xml
+++ b/storm-buildtools/maven-shade-clojure-transformer/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.2-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating</version>
<relativePath>../../pom.xml</relativePath>
</parent>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/24d4a14d/storm-core/pom.xml
----------------------------------------------------------------------
diff --git a/storm-core/pom.xml b/storm-core/pom.xml
index 26f08cb..34118fe 100644
--- a/storm-core/pom.xml
+++ b/storm-core/pom.xml
@@ -20,7 +20,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.2-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating</version>
</parent>
<groupId>org.apache.storm</groupId>
<artifactId>storm-core</artifactId>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/24d4a14d/storm-dist/binary/pom.xml
----------------------------------------------------------------------
diff --git a/storm-dist/binary/pom.xml b/storm-dist/binary/pom.xml
index 4fa3a27..6ffe62d 100644
--- a/storm-dist/binary/pom.xml
+++ b/storm-dist/binary/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.2-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating</version>
<relativePath>../../pom.xml</relativePath>
</parent>
<groupId>org.apache.storm</groupId>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/24d4a14d/storm-dist/source/pom.xml
----------------------------------------------------------------------
diff --git a/storm-dist/source/pom.xml b/storm-dist/source/pom.xml
index b5552df..2bd815b 100644
--- a/storm-dist/source/pom.xml
+++ b/storm-dist/source/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.2-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating</version>
<relativePath>../../pom.xml</relativePath>
</parent>
<groupId>org.apache.storm</groupId>
[17/23] git commit: [maven-release-plugin] prepare release
v0.9.2-incubating
Posted by bo...@apache.org.
[maven-release-plugin] prepare release v0.9.2-incubating
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/f037b41c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/f037b41c
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/f037b41c
Branch: refs/heads/security
Commit: f037b41c82e03017b5f894156096f9f96c59f600
Parents: 18b3db9
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Thu Jun 12 20:51:37 2014 -0400
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Thu Jun 12 20:51:37 2014 -0400
----------------------------------------------------------------------
examples/storm-starter/pom.xml | 2 +-
external/storm-kafka/pom.xml | 2 +-
pom.xml | 4 ++--
storm-buildtools/maven-shade-clojure-transformer/pom.xml | 2 +-
storm-core/pom.xml | 2 +-
storm-dist/binary/pom.xml | 2 +-
storm-dist/source/pom.xml | 2 +-
7 files changed, 8 insertions(+), 8 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/f037b41c/examples/storm-starter/pom.xml
----------------------------------------------------------------------
diff --git a/examples/storm-starter/pom.xml b/examples/storm-starter/pom.xml
index 182546f..0e0d920 100644
--- a/examples/storm-starter/pom.xml
+++ b/examples/storm-starter/pom.xml
@@ -20,7 +20,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.2-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating</version>
<relativePath>../../pom.xml</relativePath>
</parent>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/f037b41c/external/storm-kafka/pom.xml
----------------------------------------------------------------------
diff --git a/external/storm-kafka/pom.xml b/external/storm-kafka/pom.xml
index ff411a3..a9d9a6d 100644
--- a/external/storm-kafka/pom.xml
+++ b/external/storm-kafka/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.2-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating</version>
<relativePath>../../pom.xml</relativePath>
</parent>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/f037b41c/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index ce10cc2..cba38e3 100644
--- a/pom.xml
+++ b/pom.xml
@@ -27,7 +27,7 @@
<groupId>org.apache.storm</groupId>
<artifactId>storm</artifactId>
- <version>0.9.2-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating</version>
<packaging>pom</packaging>
<name>Storm</name>
<description>Distributed and fault-tolerant realtime computation</description>
@@ -164,7 +164,7 @@
<scm>
<connection>scm:git:https://git-wip-us.apache.org/repos/asf/incubator-storm.git</connection>
<developerConnection>scm:git:https://git-wip-us.apache.org/repos/asf/incubator-storm.git</developerConnection>
- <tag>HEAD</tag>
+ <tag>v0.9.2-incubating</tag>
<url>https://git-wip-us.apache.org/repos/asf/incubator-storm</url>
</scm>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/f037b41c/storm-buildtools/maven-shade-clojure-transformer/pom.xml
----------------------------------------------------------------------
diff --git a/storm-buildtools/maven-shade-clojure-transformer/pom.xml b/storm-buildtools/maven-shade-clojure-transformer/pom.xml
index 7dfa2a2..27d0cfe 100644
--- a/storm-buildtools/maven-shade-clojure-transformer/pom.xml
+++ b/storm-buildtools/maven-shade-clojure-transformer/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.2-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating</version>
<relativePath>../../pom.xml</relativePath>
</parent>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/f037b41c/storm-core/pom.xml
----------------------------------------------------------------------
diff --git a/storm-core/pom.xml b/storm-core/pom.xml
index 26f08cb..34118fe 100644
--- a/storm-core/pom.xml
+++ b/storm-core/pom.xml
@@ -20,7 +20,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.2-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating</version>
</parent>
<groupId>org.apache.storm</groupId>
<artifactId>storm-core</artifactId>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/f037b41c/storm-dist/binary/pom.xml
----------------------------------------------------------------------
diff --git a/storm-dist/binary/pom.xml b/storm-dist/binary/pom.xml
index 4fa3a27..6ffe62d 100644
--- a/storm-dist/binary/pom.xml
+++ b/storm-dist/binary/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.2-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating</version>
<relativePath>../../pom.xml</relativePath>
</parent>
<groupId>org.apache.storm</groupId>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/f037b41c/storm-dist/source/pom.xml
----------------------------------------------------------------------
diff --git a/storm-dist/source/pom.xml b/storm-dist/source/pom.xml
index b5552df..2bd815b 100644
--- a/storm-dist/source/pom.xml
+++ b/storm-dist/source/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.2-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating</version>
<relativePath>../../pom.xml</relativePath>
</parent>
<groupId>org.apache.storm</groupId>
[20/23] git commit: rollback poms for 0.9.2-incubating re-release
Posted by bo...@apache.org.
rollback poms for 0.9.2-incubating re-release
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/87a16c1a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/87a16c1a
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/87a16c1a
Branch: refs/heads/security
Commit: 87a16c1a885c6381a3bc1d532e5105660196a2cb
Parents: d448e34
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Fri Jun 13 14:37:45 2014 -0400
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Fri Jun 13 14:37:45 2014 -0400
----------------------------------------------------------------------
examples/storm-starter/pom.xml | 2 +-
external/storm-kafka/pom.xml | 2 +-
pom.xml | 2 +-
storm-buildtools/maven-shade-clojure-transformer/pom.xml | 2 +-
storm-core/pom.xml | 2 +-
storm-dist/binary/pom.xml | 2 +-
storm-dist/source/pom.xml | 2 +-
7 files changed, 7 insertions(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/87a16c1a/examples/storm-starter/pom.xml
----------------------------------------------------------------------
diff --git a/examples/storm-starter/pom.xml b/examples/storm-starter/pom.xml
index 903c6e7..182546f 100644
--- a/examples/storm-starter/pom.xml
+++ b/examples/storm-starter/pom.xml
@@ -20,7 +20,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.3-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating-SNAPSHOT</version>
<relativePath>../../pom.xml</relativePath>
</parent>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/87a16c1a/external/storm-kafka/pom.xml
----------------------------------------------------------------------
diff --git a/external/storm-kafka/pom.xml b/external/storm-kafka/pom.xml
index 4972619..ff411a3 100644
--- a/external/storm-kafka/pom.xml
+++ b/external/storm-kafka/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.3-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating-SNAPSHOT</version>
<relativePath>../../pom.xml</relativePath>
</parent>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/87a16c1a/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index b7286dc..ce10cc2 100644
--- a/pom.xml
+++ b/pom.xml
@@ -27,7 +27,7 @@
<groupId>org.apache.storm</groupId>
<artifactId>storm</artifactId>
- <version>0.9.3-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating-SNAPSHOT</version>
<packaging>pom</packaging>
<name>Storm</name>
<description>Distributed and fault-tolerant realtime computation</description>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/87a16c1a/storm-buildtools/maven-shade-clojure-transformer/pom.xml
----------------------------------------------------------------------
diff --git a/storm-buildtools/maven-shade-clojure-transformer/pom.xml b/storm-buildtools/maven-shade-clojure-transformer/pom.xml
index a6fbad1..7dfa2a2 100644
--- a/storm-buildtools/maven-shade-clojure-transformer/pom.xml
+++ b/storm-buildtools/maven-shade-clojure-transformer/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.3-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating-SNAPSHOT</version>
<relativePath>../../pom.xml</relativePath>
</parent>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/87a16c1a/storm-core/pom.xml
----------------------------------------------------------------------
diff --git a/storm-core/pom.xml b/storm-core/pom.xml
index 45878f6..26f08cb 100644
--- a/storm-core/pom.xml
+++ b/storm-core/pom.xml
@@ -20,7 +20,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.3-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating-SNAPSHOT</version>
</parent>
<groupId>org.apache.storm</groupId>
<artifactId>storm-core</artifactId>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/87a16c1a/storm-dist/binary/pom.xml
----------------------------------------------------------------------
diff --git a/storm-dist/binary/pom.xml b/storm-dist/binary/pom.xml
index 0d97c0b..4fa3a27 100644
--- a/storm-dist/binary/pom.xml
+++ b/storm-dist/binary/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.3-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating-SNAPSHOT</version>
<relativePath>../../pom.xml</relativePath>
</parent>
<groupId>org.apache.storm</groupId>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/87a16c1a/storm-dist/source/pom.xml
----------------------------------------------------------------------
diff --git a/storm-dist/source/pom.xml b/storm-dist/source/pom.xml
index 4fedefb..b5552df 100644
--- a/storm-dist/source/pom.xml
+++ b/storm-dist/source/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.3-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating-SNAPSHOT</version>
<relativePath>../../pom.xml</relativePath>
</parent>
<groupId>org.apache.storm</groupId>
[15/23] git commit: [maven-release-plugin] rollback the release of
v0.9.2-incubating
Posted by bo...@apache.org.
[maven-release-plugin] rollback the release of v0.9.2-incubating
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/4650914d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/4650914d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/4650914d
Branch: refs/heads/security
Commit: 4650914ddd56d45ff3af0445c959d74d69019e5e
Parents: 4a65307
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Thu Jun 12 20:45:36 2014 -0400
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Thu Jun 12 20:45:36 2014 -0400
----------------------------------------------------------------------
examples/storm-starter/pom.xml | 2 +-
external/storm-kafka/pom.xml | 2 +-
pom.xml | 2 +-
storm-buildtools/maven-shade-clojure-transformer/pom.xml | 2 +-
storm-core/pom.xml | 2 +-
storm-dist/binary/pom.xml | 2 +-
storm-dist/source/pom.xml | 2 +-
7 files changed, 7 insertions(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/4650914d/examples/storm-starter/pom.xml
----------------------------------------------------------------------
diff --git a/examples/storm-starter/pom.xml b/examples/storm-starter/pom.xml
index 903c6e7..182546f 100644
--- a/examples/storm-starter/pom.xml
+++ b/examples/storm-starter/pom.xml
@@ -20,7 +20,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.3-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating-SNAPSHOT</version>
<relativePath>../../pom.xml</relativePath>
</parent>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/4650914d/external/storm-kafka/pom.xml
----------------------------------------------------------------------
diff --git a/external/storm-kafka/pom.xml b/external/storm-kafka/pom.xml
index 4972619..ff411a3 100644
--- a/external/storm-kafka/pom.xml
+++ b/external/storm-kafka/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.3-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating-SNAPSHOT</version>
<relativePath>../../pom.xml</relativePath>
</parent>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/4650914d/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index b7286dc..ce10cc2 100644
--- a/pom.xml
+++ b/pom.xml
@@ -27,7 +27,7 @@
<groupId>org.apache.storm</groupId>
<artifactId>storm</artifactId>
- <version>0.9.3-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating-SNAPSHOT</version>
<packaging>pom</packaging>
<name>Storm</name>
<description>Distributed and fault-tolerant realtime computation</description>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/4650914d/storm-buildtools/maven-shade-clojure-transformer/pom.xml
----------------------------------------------------------------------
diff --git a/storm-buildtools/maven-shade-clojure-transformer/pom.xml b/storm-buildtools/maven-shade-clojure-transformer/pom.xml
index a6fbad1..7dfa2a2 100644
--- a/storm-buildtools/maven-shade-clojure-transformer/pom.xml
+++ b/storm-buildtools/maven-shade-clojure-transformer/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.3-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating-SNAPSHOT</version>
<relativePath>../../pom.xml</relativePath>
</parent>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/4650914d/storm-core/pom.xml
----------------------------------------------------------------------
diff --git a/storm-core/pom.xml b/storm-core/pom.xml
index 45878f6..26f08cb 100644
--- a/storm-core/pom.xml
+++ b/storm-core/pom.xml
@@ -20,7 +20,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.3-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating-SNAPSHOT</version>
</parent>
<groupId>org.apache.storm</groupId>
<artifactId>storm-core</artifactId>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/4650914d/storm-dist/binary/pom.xml
----------------------------------------------------------------------
diff --git a/storm-dist/binary/pom.xml b/storm-dist/binary/pom.xml
index 0d97c0b..4fa3a27 100644
--- a/storm-dist/binary/pom.xml
+++ b/storm-dist/binary/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.3-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating-SNAPSHOT</version>
<relativePath>../../pom.xml</relativePath>
</parent>
<groupId>org.apache.storm</groupId>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/4650914d/storm-dist/source/pom.xml
----------------------------------------------------------------------
diff --git a/storm-dist/source/pom.xml b/storm-dist/source/pom.xml
index 4fedefb..b5552df 100644
--- a/storm-dist/source/pom.xml
+++ b/storm-dist/source/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.3-incubating-SNAPSHOT</version>
+ <version>0.9.2-incubating-SNAPSHOT</version>
<relativePath>../../pom.xml</relativePath>
</parent>
<groupId>org.apache.storm</groupId>
[09/23] git commit: Merge branch 'STORM-66' of
https://github.com/tuxpiper/incubator-storm into STORM-66
Posted by bo...@apache.org.
Merge branch 'STORM-66' of https://github.com/tuxpiper/incubator-storm into STORM-66
STORM-66: send taskid on initial handshake
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/00cc9c6a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/00cc9c6a
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/00cc9c6a
Branch: refs/heads/security
Commit: 00cc9c6af6022af246e4bc409f6ffcc85e88ada4
Parents: 0826b93 47dba86
Author: Robert (Bobby) Evans <bo...@apache.org>
Authored: Thu Jun 12 16:37:05 2014 -0500
Committer: Robert (Bobby) Evans <bo...@apache.org>
Committed: Thu Jun 12 16:37:05 2014 -0500
----------------------------------------------------------------------
.../src/jvm/backtype/storm/task/TopologyContext.java | 11 +++++++++++
1 file changed, 11 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/00cc9c6a/storm-core/src/jvm/backtype/storm/task/TopologyContext.java
----------------------------------------------------------------------
[23/23] git commit: Merge tag 'v0.9.2-incubating' into security
Posted by bo...@apache.org.
Merge tag 'v0.9.2-incubating' into security
[maven-release-plugin] copy for tag v0.9.2-incubating
Conflicts:
storm-core/pom.xml
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/79089ad0
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/79089ad0
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/79089ad0
Branch: refs/heads/security
Commit: 79089ad0da80e38eb36b7ea91be8b43795dc4efb
Parents: 87cdbf5 24d4a14
Author: Robert (Bobby) Evans <bo...@apache.org>
Authored: Thu Jun 19 16:04:02 2014 -0500
Committer: Robert (Bobby) Evans <bo...@apache.org>
Committed: Thu Jun 19 16:04:02 2014 -0500
----------------------------------------------------------------------
CHANGELOG.md | 6 +-
examples/storm-starter/pom.xml | 2 +-
external/storm-kafka/pom.xml | 2 +-
.../src/jvm/storm/kafka/PartitionManager.java | 2 +-
pom.xml | 4 +-
.../maven-shade-clojure-transformer/pom.xml | 2 +-
storm-core/pom.xml | 14 +-
.../backtype/storm/task/TopologyContext.java | 11 ++
.../backtype/storm/utils/DisruptorQueue.java | 70 ++++++---
.../storm/utils/DisruptorQueueTest.java | 153 +++++++++++++++++++
storm-dist/binary/pom.xml | 2 +-
storm-dist/source/pom.xml | 2 +-
12 files changed, 237 insertions(+), 33 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/79089ad0/pom.xml
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/79089ad0/storm-core/pom.xml
----------------------------------------------------------------------
[06/23] git commit: fix testMessageDisorder() to assert after calling
run()
Posted by bo...@apache.org.
fix testMessageDisorder() to assert after calling run()
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/405dabbc
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/405dabbc
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/405dabbc
Branch: refs/heads/security
Commit: 405dabbc8e67f72a8c04e95c0b562dc2826c01a1
Parents: f1bf9cd
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Thu Jun 12 16:55:43 2014 -0400
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Thu Jun 12 16:55:43 2014 -0400
----------------------------------------------------------------------
.../test/jvm/backtype/storm/utils/DisruptorQueueTest.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/405dabbc/storm-core/test/jvm/backtype/storm/utils/DisruptorQueueTest.java
----------------------------------------------------------------------
diff --git a/storm-core/test/jvm/backtype/storm/utils/DisruptorQueueTest.java b/storm-core/test/jvm/backtype/storm/utils/DisruptorQueueTest.java
index f21b10f..747d95c 100644
--- a/storm-core/test/jvm/backtype/storm/utils/DisruptorQueueTest.java
+++ b/storm-core/test/jvm/backtype/storm/utils/DisruptorQueueTest.java
@@ -55,10 +55,10 @@ public class DisruptorQueueTest extends TestCase {
}
}
});
-
- Assert.assertEquals("We expect to receive first published message first, but received " + result[0].toString(),
- "1", result[0]);
+
run(producer, consumer);
+ Assert.assertEquals("We expect to receive first published message first, but received " + result[0],
+ "1", result[0]);
}
@Test
[14/23] git commit: [maven-release-plugin] prepare for next
development iteration
Posted by bo...@apache.org.
[maven-release-plugin] prepare for next development iteration
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/4a653079
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/4a653079
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/4a653079
Branch: refs/heads/security
Commit: 4a653079ef2a0b4baf644083118404a3506a5e31
Parents: 09e50c1
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Thu Jun 12 20:44:57 2014 -0400
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Thu Jun 12 20:44:57 2014 -0400
----------------------------------------------------------------------
examples/storm-starter/pom.xml | 2 +-
external/storm-kafka/pom.xml | 2 +-
pom.xml | 4 ++--
storm-buildtools/maven-shade-clojure-transformer/pom.xml | 2 +-
storm-core/pom.xml | 2 +-
storm-dist/binary/pom.xml | 2 +-
storm-dist/source/pom.xml | 2 +-
7 files changed, 8 insertions(+), 8 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/4a653079/examples/storm-starter/pom.xml
----------------------------------------------------------------------
diff --git a/examples/storm-starter/pom.xml b/examples/storm-starter/pom.xml
index 0e0d920..903c6e7 100644
--- a/examples/storm-starter/pom.xml
+++ b/examples/storm-starter/pom.xml
@@ -20,7 +20,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.2-incubating</version>
+ <version>0.9.3-incubating-SNAPSHOT</version>
<relativePath>../../pom.xml</relativePath>
</parent>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/4a653079/external/storm-kafka/pom.xml
----------------------------------------------------------------------
diff --git a/external/storm-kafka/pom.xml b/external/storm-kafka/pom.xml
index a9d9a6d..4972619 100644
--- a/external/storm-kafka/pom.xml
+++ b/external/storm-kafka/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.2-incubating</version>
+ <version>0.9.3-incubating-SNAPSHOT</version>
<relativePath>../../pom.xml</relativePath>
</parent>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/4a653079/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index cba38e3..b7286dc 100644
--- a/pom.xml
+++ b/pom.xml
@@ -27,7 +27,7 @@
<groupId>org.apache.storm</groupId>
<artifactId>storm</artifactId>
- <version>0.9.2-incubating</version>
+ <version>0.9.3-incubating-SNAPSHOT</version>
<packaging>pom</packaging>
<name>Storm</name>
<description>Distributed and fault-tolerant realtime computation</description>
@@ -164,7 +164,7 @@
<scm>
<connection>scm:git:https://git-wip-us.apache.org/repos/asf/incubator-storm.git</connection>
<developerConnection>scm:git:https://git-wip-us.apache.org/repos/asf/incubator-storm.git</developerConnection>
- <tag>v0.9.2-incubating</tag>
+ <tag>HEAD</tag>
<url>https://git-wip-us.apache.org/repos/asf/incubator-storm</url>
</scm>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/4a653079/storm-buildtools/maven-shade-clojure-transformer/pom.xml
----------------------------------------------------------------------
diff --git a/storm-buildtools/maven-shade-clojure-transformer/pom.xml b/storm-buildtools/maven-shade-clojure-transformer/pom.xml
index 27d0cfe..a6fbad1 100644
--- a/storm-buildtools/maven-shade-clojure-transformer/pom.xml
+++ b/storm-buildtools/maven-shade-clojure-transformer/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.2-incubating</version>
+ <version>0.9.3-incubating-SNAPSHOT</version>
<relativePath>../../pom.xml</relativePath>
</parent>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/4a653079/storm-core/pom.xml
----------------------------------------------------------------------
diff --git a/storm-core/pom.xml b/storm-core/pom.xml
index 34118fe..45878f6 100644
--- a/storm-core/pom.xml
+++ b/storm-core/pom.xml
@@ -20,7 +20,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.2-incubating</version>
+ <version>0.9.3-incubating-SNAPSHOT</version>
</parent>
<groupId>org.apache.storm</groupId>
<artifactId>storm-core</artifactId>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/4a653079/storm-dist/binary/pom.xml
----------------------------------------------------------------------
diff --git a/storm-dist/binary/pom.xml b/storm-dist/binary/pom.xml
index 6ffe62d..0d97c0b 100644
--- a/storm-dist/binary/pom.xml
+++ b/storm-dist/binary/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.2-incubating</version>
+ <version>0.9.3-incubating-SNAPSHOT</version>
<relativePath>../../pom.xml</relativePath>
</parent>
<groupId>org.apache.storm</groupId>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/4a653079/storm-dist/source/pom.xml
----------------------------------------------------------------------
diff --git a/storm-dist/source/pom.xml b/storm-dist/source/pom.xml
index 2bd815b..4fedefb 100644
--- a/storm-dist/source/pom.xml
+++ b/storm-dist/source/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.9.2-incubating</version>
+ <version>0.9.3-incubating-SNAPSHOT</version>
<relativePath>../../pom.xml</relativePath>
</parent>
<groupId>org.apache.storm</groupId>