storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From da...@apache.org
Subject [1/3] storm git commit: Fix spout close: close spout when emitter closed
Date Mon, 23 Feb 2015 16:52:48 GMT
Repository: storm
Updated Branches:
  refs/heads/master ffb1816a9 -> 740609b14


Fix spout close: close spout when emitter closed


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

Branch: refs/heads/master
Commit: 842b5526469bc6c2fe763498faf4dfb76fcadcd7
Parents: 82caf66
Author: Zhihui Jiao <zhihui.jiao@gmail.com>
Authored: Wed Jan 28 11:17:43 2015 +0800
Committer: Zhihui Jiao <zhihui.jiao@gmail.com>
Committed: Wed Jan 28 11:17:43 2015 +0800

----------------------------------------------------------------------
 storm-core/src/jvm/storm/trident/spout/RichSpoutBatchExecutor.java | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/842b5526/storm-core/src/jvm/storm/trident/spout/RichSpoutBatchExecutor.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/storm/trident/spout/RichSpoutBatchExecutor.java b/storm-core/src/jvm/storm/trident/spout/RichSpoutBatchExecutor.java
index 9de85e6..345a5a0 100644
--- a/storm-core/src/jvm/storm/trident/spout/RichSpoutBatchExecutor.java
+++ b/storm-core/src/jvm/storm/trident/spout/RichSpoutBatchExecutor.java
@@ -140,6 +140,7 @@ public class RichSpoutBatchExecutor implements ITridentSpout {
         
         @Override
         public void close() {
+            _spout.close();
         }
         
     }


Mime
View raw message