Repository: incubator-apex-core Updated Branches: refs/heads/master b3768f38c -> 99aa417d9
APEXCORE-335 tear down StreamingContainerManager Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/commit/058833c3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/058833c3 Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/058833c3 Branch: refs/heads/master Commit: 058833c31f36bc9ce871eba3350100893ecaa74c Parents: bbc4257 Author: Vlad Rozov <[email protected]> Authored: Tue Feb 9 15:39:38 2016 -0800 Committer: Vlad Rozov <[email protected]> Committed: Tue Feb 9 15:39:38 2016 -0800 ---------------------------------------------------------------------- engine/src/main/java/com/datatorrent/stram/StramLocalCluster.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/058833c3/engine/src/main/java/com/datatorrent/stram/StramLocalCluster.java ---------------------------------------------------------------------- diff --git a/engine/src/main/java/com/datatorrent/stram/StramLocalCluster.java b/engine/src/main/java/com/datatorrent/stram/StramLocalCluster.java index cda2a38..d0a6ed9 100644 --- a/engine/src/main/java/com/datatorrent/stram/StramLocalCluster.java +++ b/engine/src/main/java/com/datatorrent/stram/StramLocalCluster.java @@ -511,6 +511,8 @@ public class StramLocalCluster implements Runnable, Controller lsc.triggerHeartbeat(); } + dnmgr.teardown(); + LOG.info("Application finished."); if (!perContainerBufferServer) { StreamingContainer.eventloop.stop(bufferServer);
