kill subprocess when ShellSpout.die() called
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/8b8a443c Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/8b8a443c Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/8b8a443c Branch: refs/heads/0.9.3-branch Commit: 8b8a443cbf5896985e0ab38e69baadec57bbe5d0 Parents: 4095078 Author: Jungtaek Lim <[email protected]> Authored: Sat Oct 11 22:06:51 2014 +0900 Committer: Jungtaek Lim <[email protected]> Committed: Sat Oct 11 22:06:51 2014 +0900 ---------------------------------------------------------------------- storm-core/src/jvm/backtype/storm/spout/ShellSpout.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/8b8a443c/storm-core/src/jvm/backtype/storm/spout/ShellSpout.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/backtype/storm/spout/ShellSpout.java b/storm-core/src/jvm/backtype/storm/spout/ShellSpout.java index 6cc6196..f257b42 100644 --- a/storm-core/src/jvm/backtype/storm/spout/ShellSpout.java +++ b/storm-core/src/jvm/backtype/storm/spout/ShellSpout.java @@ -229,6 +229,7 @@ public class ShellSpout implements ISpout { LOG.error("Halting process: ShellSpout died.", exception); _collector.reportError(exception); + _process.destroy(); System.exit(11); }
