You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by bh...@apache.org on 2017/04/16 08:15:58 UTC
apex-core git commit: APEXCORE-678 Fixed shutdown of input nodes in
StreamingContainer
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 <bh...@apache.org>
Authored: Thu Mar 23 16:57:33 2017 +0530
Committer: bhupeshchawda <bh...@apache.org>
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);
}
}