You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by da...@apache.org on 2015/02/23 17:52:48 UTC

[1/3] storm git commit: Fix spout close: close spout when emitter closed

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 <zh...@gmail.com>
Authored: Wed Jan 28 11:17:43 2015 +0800
Committer: Zhihui Jiao <zh...@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();
         }
         
     }

[3/3] storm git commit: Updating CHANGELOG for STORM-684

Posted by da...@apache.org.
Updating CHANGELOG for STORM-684


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

Branch: refs/heads/master
Commit: 740609b14ad652e05242334c53b11334fb22c5b9
Parents: 76159b0
Author: Derek Dagit <de...@yahoo-inc.com>
Authored: Mon Feb 23 10:51:53 2015 -0600
Committer: Derek Dagit <de...@yahoo-inc.com>
Committed: Mon Feb 23 10:51:53 2015 -0600

----------------------------------------------------------------------
 CHANGELOG.md | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/740609b1/CHANGELOG.md
----------------------------------------------------------------------
diff --git a/CHANGELOG.md b/CHANGELOG.md
index 91849b1..7e0e944 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -54,6 +54,7 @@
  * STORM-441: Remove bootstrap macro from Clojure codebase
  * STORM-609: Add storm-redis to storm external
  * STORM-130: Supervisor getting killed due to java.io.FileNotFoundException: File '../stormconf.ser' does not exist.
+ * STORM-684: In RichSpoutBatchExecutor: underlying spout is not closed when emitter is closed
 
 ## 0.9.3-rc2
  * STORM-558: change "swap!" to "reset!" to fix assignment-versions in supervisor

[2/3] storm git commit: Merge branch 'fix_spout_close' of https://github.com/onlychoice/storm

Posted by da...@apache.org.
Merge branch 'fix_spout_close' of https://github.com/onlychoice/storm

STORM-684: In RichSpoutBatchExecutor: underlying spout is not closed when emitter is closed


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

Branch: refs/heads/master
Commit: 76159b017d111b4bd39936fb2e41ce886cd50089
Parents: ffb1816 842b552
Author: Derek Dagit <de...@yahoo-inc.com>
Authored: Mon Feb 23 10:50:54 2015 -0600
Committer: Derek Dagit <de...@yahoo-inc.com>
Committed: Mon Feb 23 10:50:54 2015 -0600

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