[FLINK-2002] [streaming] Test for iterations being gracefully shut down

The fix was done by gyfora in fdac963.
abhishekagarwal87 · Jun 5, 2015 · 3e6b6be · 3e6b6be
1 parent 9b88184
commit 3e6b6be
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...ing-core/src/test/java/org/apache/flink/streaming/api/complex/ComplexIntegrationTest.java b/...ing-core/src/test/java/org/apache/flink/streaming/api/complex/ComplexIntegrationTest.java
@@ -114,8 +114,7 @@ public void complexIntegrationTest1() throws Exception {
 		//i == 18
 		expected2 += "(20,(a,1))";
 
-		//We create a separate environment for this test because of the slot-related to iteration issues.
-		StreamExecutionEnvironment env = new TestStreamEnvironment(4, 32); //StreamExecutionEnvironment.getExecutionEnvironment();
+		StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
 		DataStream<Tuple2<Long, Tuple2<String, Long>>> sourceStream1 = env.addSource(new TupleSource()).setParallelism(1);
 
 		IterativeDataStream<Tuple2<Long, Tuple2<String, Long>>> it = sourceStream1.sum(0).setParallelism(1).filter(new FilterFunction