NodeControllers clean up appEntryPoints on shutdown (2nd try)
diff --git a/pregelix-runtime/src/main/java/edu/uci/ics/pregelix/runtime/bootstrap/NCApplicationEntryPoint.java b/pregelix-runtime/src/main/java/edu/uci/ics/pregelix/runtime/bootstrap/NCApplicationEntryPoint.java
index 9607494..fe72d7a 100644
--- a/pregelix-runtime/src/main/java/edu/uci/ics/pregelix/runtime/bootstrap/NCApplicationEntryPoint.java
+++ b/pregelix-runtime/src/main/java/edu/uci/ics/pregelix/runtime/bootstrap/NCApplicationEntryPoint.java
@@ -19,9 +19,11 @@
import edu.uci.ics.pregelix.dataflow.context.RuntimeContext;
public class NCApplicationEntryPoint implements INCApplicationEntryPoint {
+ private RuntimeContext rCtx = null;
+
@Override
public void start(INCApplicationContext ncAppCtx, String[] args) throws Exception {
- RuntimeContext rCtx = new RuntimeContext(ncAppCtx);
+ rCtx = new RuntimeContext(ncAppCtx);
ncAppCtx.setApplicationObject(rCtx);
}
@@ -32,6 +34,6 @@
@Override
public void stop() throws Exception {
-
+ rCtx.close();
}
}
\ No newline at end of file