apex-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From t..@apache.org
Subject [1/4] incubator-apex-core git commit: APEXCORE-335 tear down StreamingContainerManager
Date Wed, 10 Feb 2016 04:31:27 GMT
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 <v.rozov@datatorrent.com>
Authored: Tue Feb 9 15:39:38 2016 -0800
Committer: Vlad Rozov <v.rozov@datatorrent.com>
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);


Mime
View raw message