From ca85206d4b1096b5c5c83665a8bdae591eda6627 Mon Sep 17 00:00:00 2001 From: Chathura Widanage Date: Fri, 10 May 2019 13:58:50 -0400 Subject: [PATCH 1/2] Linking windowing doc --- docs/examples/README.md | 1 + 1 file changed, 1 insertion(+) diff --git a/docs/examples/README.md b/docs/examples/README.md index afd56c218a..c926166452 100644 --- a/docs/examples/README.md +++ b/docs/examples/README.md @@ -9,4 +9,5 @@ In the examples section, we discuss the following. * [MultiStage Examples](multistage/multistage_examples.md) * [Tera Sort](terasort/terasort.md) * [Machine Learning Examples](ml/README.md) +* [Windowing](windowing/windowing.md) * [benchmark Suite](benchmark/benchmark.md) \ No newline at end of file From d8ad06a4a79ab27f1164e9fef3ff7dccc1b03654 Mon Sep 17 00:00:00 2001 From: Chathura Widanage Date: Fri, 10 May 2019 14:09:09 -0400 Subject: [PATCH 2/2] setting execution state in BatchSharingExecutor --- .../edu/iu/dsc/tws/executor/threading/BatchSharingExecutor.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/twister2/executor/src/java/edu/iu/dsc/tws/executor/threading/BatchSharingExecutor.java b/twister2/executor/src/java/edu/iu/dsc/tws/executor/threading/BatchSharingExecutor.java index cdd0d4f024..adb623485a 100644 --- a/twister2/executor/src/java/edu/iu/dsc/tws/executor/threading/BatchSharingExecutor.java +++ b/twister2/executor/src/java/edu/iu/dsc/tws/executor/threading/BatchSharingExecutor.java @@ -122,6 +122,8 @@ private void cleanUp(ExecutionPlan executionPlan, Map no throw new RuntimeException("Interrupted", e); } + executionPlan.setExecutionState(ExecutionState.EXECUTED); + // clear the finished instances finishedInstances.set(0); cleanUpCalled = true;