Merge pull request #405 from chathurawidanage/master

supunkamburugamuve · web-flow · commit 7b308a256310 · 2019-05-10T14:09:20.000-04:00
Linking windowing doc
diff --git 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)
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
@@ -122,6 +122,8 @@ private void cleanUp(ExecutionPlan executionPlan, Map<Integer, INodeInstance> no
       throw new RuntimeException("Interrupted", e);
     }
 
+    executionPlan.setExecutionState(ExecutionState.EXECUTED);
+
     // clear the finished instances
     finishedInstances.set(0);
     cleanUpCalled = true;

Original file line number	Diff line number	Diff line change
`@@ -122,6 +122,8 @@ private void cleanUp(ExecutionPlan executionPlan, Map<Integer, INodeInstance> no`
`122`	`122`	`throw new RuntimeException("Interrupted", e);`
`123`	`123`	`}`
`124`	`124`
	`125`	`+ executionPlan.setExecutionState(ExecutionState.EXECUTED);`
	`126`	`+`
`125`	`127`	`// clear the finished instances`
`126`	`128`	`finishedInstances.set(0);`
`127`	`129`	`cleanUpCalled = true;`