[hotfix][tests] Remove try/catch from SavepointWindowReaderITCase.tes…

…tApplyEvictorWindowStateReader
kaicao · May 18, 2021 · 7399bb4 · 7399bb4
1 parent 0528f84
commit 7399bb4
Showing 1 changed file with 11 additions and 15 deletions.
diff --git a/...-processing-api/src/test/java/org/apache/flink/state/api/SavepointWindowReaderITCase.java b/...-processing-api/src/test/java/org/apache/flink/state/api/SavepointWindowReaderITCase.java
@@ -318,21 +318,17 @@ public void testApplyEvictorWindowStateReader() throws Exception {
         env.setStateBackend(getStateBackend());
         env.setParallelism(4);
 
-        try {
-            env.addSource(createSource(numbers))
-                    .rebalance()
-                    .assignTimestampsAndWatermarks(
-                            WatermarkStrategy.<Integer>noWatermarks()
-                                    .withTimestampAssigner((event, timestamp) -> 0))
-                    .keyBy(id -> id)
-                    .window(TumblingEventTimeWindows.of(Time.milliseconds(10)))
-                    .evictor(new NoOpEvictor<>())
-                    .apply(new NoOpWindowFunction())
-                    .uid(uid)
-                    .addSink(new DiscardingSink<>());
-        } catch (Exception e) {
-            e.printStackTrace();
-        }
+        env.addSource(createSource(numbers))
+                .rebalance()
+                .assignTimestampsAndWatermarks(
+                        WatermarkStrategy.<Integer>noWatermarks()
+                                .withTimestampAssigner((event, timestamp) -> 0))
+                .keyBy(id -> id)
+                .window(TumblingEventTimeWindows.of(Time.milliseconds(10)))
+                .evictor(new NoOpEvictor<>())
+                .apply(new NoOpWindowFunction())
+                .uid(uid)
+                .addSink(new DiscardingSink<>());
 
         String savepointPath = takeSavepoint(env);