storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bo...@apache.org
Subject [24/32] git commit: STORM-297: fix flusher bug, dead loop
Date Mon, 09 Jun 2014 13:48:29 GMT
STORM-297: fix flusher bug, dead loop


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

Branch: refs/heads/master
Commit: 0bca1733d64a92d8ec411f5fdf41ebc90a1bddef
Parents: 426d143
Author: Sean Zhong <clockfly@gmail.com>
Authored: Tue Jun 3 14:53:10 2014 +0800
Committer: Sean Zhong <clockfly@gmail.com>
Committed: Tue Jun 3 14:53:10 2014 +0800

----------------------------------------------------------------------
 storm-core/src/jvm/backtype/storm/messaging/netty/Client.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/0bca1733/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java b/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java
index 9765647..8d2d221 100644
--- a/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java
+++ b/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java
@@ -109,7 +109,7 @@ public class Client implements IConnection {
             @Override
             public void run() {
 
-                while(!closing) {
+                if(!closing) {
                     long flushCheckTime = flushCheckTimer.get();
                     long now = System.currentTimeMillis();
                     if (now > flushCheckTime) {


Mime
View raw message