[flink] 01/03: [hotfix][tests] SynchronousCheckpointITCase: set test run timeout limit

[pnowojski]

This is an automated email from the ASF dual-hosted git repository.

pnowojski pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 666d887f7fa5e6ea7cad3724c3c6095f23e1a96b
Author: Aleksey Pak <alek...@ververica.com>
AuthorDate: Mon Jun 3 22:38:43 2019 +0200

    [hotfix][tests] SynchronousCheckpointITCase: set test run timeout limit
---
 .../flink/streaming/runtime/tasks/SynchronousCheckpointITCase.java   | 5 +++++
 1 file changed, 5 insertions(+)

diff --git 
a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SynchronousCheckpointITCase.java
 
b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SynchronousCheckpointITCase.java
index ab3bcf8..e33bc36 100644
--- 
a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SynchronousCheckpointITCase.java
+++ 
b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SynchronousCheckpointITCase.java
@@ -66,7 +66,9 @@ import 
org.apache.flink.runtime.util.TestingTaskManagerRuntimeInfo;
 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 class SynchronousCheckpointITCase {
                error.set(null);
        }
 
+       @Rule
+       public final Timeout timeoutPerTest = Timeout.seconds(10);
+
        @Test
        public void taskCachedThreadPoolAllowsForSynchronousCheckpoints() 
throws Exception {
                final Task task = 
createTask(SynchronousCheckpointTestingTask.class);