storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kabh...@apache.org
Subject [1/8] storm git commit: fix issue of high cpu usage when bolt idle
Date Thu, 16 Jul 2015 23:32:21 GMT
Repository: storm
Updated Branches:
  refs/heads/0.9.x-branch ff42a3deb -> f17b4151f


fix issue of high cpu usage when bolt idle


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

Branch: refs/heads/0.9.x-branch
Commit: 979e23cd73bbbb55ccadf9df9d62ac60b27e063e
Parents: ff42a3d
Author: errordaiwa <xingyusu@outlook.com>
Authored: Thu Jul 9 10:40:20 2015 +0800
Committer: Jungtaek Lim <kabhwan@gmail.com>
Committed: Fri Jul 17 08:16:55 2015 +0900

----------------------------------------------------------------------
 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/storm/blob/979e23cd/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 932af16..1f2110d 100644
--- a/storm-core/src/jvm/backtype/storm/utils/DisruptorQueue.java
+++ b/storm-core/src/jvm/backtype/storm/utils/DisruptorQueue.java
@@ -94,7 +94,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, 10, TimeUnit.MILLISECONDS);
+            final long availableSequence = _barrier.waitFor(nextSequence, 1000, TimeUnit.MILLISECONDS);
             if(availableSequence >= nextSequence) {
                 consumeBatchToCursor(availableSequence, handler);
             }


Mime
View raw message