storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kabh...@apache.org
Subject [4/8] storm git commit: update version of Disruptor queue to 2.10.4, consumer of queue will use waitfor method without timeout
Date Thu, 16 Jul 2015 23:32:24 GMT
update version of Disruptor queue to 2.10.4, consumer of queue will use waitfor method without
timeout

Conflicts:
	storm-core/src/jvm/backtype/storm/utils/DisruptorQueue.java


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

Branch: refs/heads/0.9.x-branch
Commit: b3c5dc99a46d2f045cc7843732d5711aacefef32
Parents: 511ba02
Author: errordaiwa <xingyusu@outlook.com>
Authored: Mon Jul 13 17:46:16 2015 +0800
Committer: Jungtaek Lim <kabhwan@gmail.com>
Committed: Fri Jul 17 08:22:56 2015 +0900

----------------------------------------------------------------------
 pom.xml                                                     | 2 +-
 storm-core/src/jvm/backtype/storm/utils/DisruptorQueue.java | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/b3c5dc99/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index 80fa42b..105838d 100644
--- a/pom.xml
+++ b/pom.xml
@@ -196,7 +196,7 @@
         <snakeyaml.version>1.11</snakeyaml.version>
         <httpclient.version>4.3.3</httpclient.version>
         <clojure.tools.cli.version>0.2.4</clojure.tools.cli.version>
-        <disruptor.version>2.10.1</disruptor.version>
+        <disruptor.version>2.10.4</disruptor.version>
         <jgrapht.version>0.9.0</jgrapht.version>
         <guava.version>16.0.1</guava.version>
         <logback-classic.version>1.0.13</logback-classic.version>

http://git-wip-us.apache.org/repos/asf/storm/blob/b3c5dc99/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 195c2f7..c4c936a 100644
--- a/storm-core/src/jvm/backtype/storm/utils/DisruptorQueue.java
+++ b/storm-core/src/jvm/backtype/storm/utils/DisruptorQueue.java
@@ -98,7 +98,7 @@ public class DisruptorQueue implements IStatefulObject {
     public void consumeBatchWhenAvailable(EventHandler<Object> handler) {
         try {
             final long nextSequence = _consumer.get() + 1;
-            final long availableSequence = _barrier.waitFor(nextSequence, _waitTimeout, TimeUnit.MILLISECONDS);
+            final long availableSequence = _barrier.waitFor(nextSequence);
             if(availableSequence >= nextSequence) {
                 consumeBatchToCursor(availableSequence, handler);
             }


Mime
View raw message