[hotfix][tests] SynchronousCheckpointITCase: set test run timeout limit

mbalassi · Jun 14, 2019 · 666d887 · 666d887
1 parent bdcef35
commit 666d887
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/...a/src/test/java/org/apache/flink/streaming/runtime/tasks/SynchronousCheckpointITCase.java b/...a/src/test/java/org/apache/flink/streaming/runtime/tasks/SynchronousCheckpointITCase.java
@@ -66,7 +66,9 @@
 import org.apache.flink.util.SerializedValue;
 
 import org.junit.Before;
+import org.junit.Rule;
 import org.junit.Test;
+import org.junit.rules.Timeout;
 
 import java.util.Collections;
 import java.util.concurrent.Executor;
@@ -108,6 +110,9 @@ public void initializeLatchesAndError() {
  error.set(null);
  }
 
+ @Rule
+ public final Timeout timeoutPerTest = Timeout.seconds(10);
+
  @Test
  public void taskCachedThreadPoolAllowsForSynchronousCheckpoints() throws Exception {
  final Task task = createTask(SynchronousCheckpointTestingTask.class);