Repository: apex-core Updated Branches: refs/heads/master 6f2b35de5 -> e9b01c53f
APEXCORE-678 Fixed shutdown of input nodes in StreamingContainer Project: http://git-wip-us.apache.org/repos/asf/apex-core/repo Commit: http://git-wip-us.apache.org/repos/asf/apex-core/commit/e9b01c53 Tree: http://git-wip-us.apache.org/repos/asf/apex-core/tree/e9b01c53 Diff: http://git-wip-us.apache.org/repos/asf/apex-core/diff/e9b01c53 Branch: refs/heads/master Commit: e9b01c53f1243944000b912d893eb8ee1234345e Parents: 6f2b35d Author: bhupeshchawda <[email protected]> Authored: Thu Mar 23 16:57:33 2017 +0530 Committer: bhupeshchawda <[email protected]> Committed: Sun Apr 16 13:05:50 2017 +0530 ---------------------------------------------------------------------- .../main/java/com/datatorrent/stram/engine/StreamingContainer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/apex-core/blob/e9b01c53/engine/src/main/java/com/datatorrent/stram/engine/StreamingContainer.java ---------------------------------------------------------------------- diff --git a/engine/src/main/java/com/datatorrent/stram/engine/StreamingContainer.java b/engine/src/main/java/com/datatorrent/stram/engine/StreamingContainer.java index e1e2ce8..dd215a9 100644 --- a/engine/src/main/java/com/datatorrent/stram/engine/StreamingContainer.java +++ b/engine/src/main/java/com/datatorrent/stram/engine/StreamingContainer.java @@ -849,8 +849,8 @@ public class StreamingContainer extends YarnContainerMain if (thread == null || !thread.isAlive()) { continue; } + node.shutdown(true); } - node.shutdown(true); } }
