[flink] 02/02: [FLINK-20432] Add timeouts to SQLClientSchemaRegistryITCase

[dwysakowicz]

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

dwysakowicz pushed a commit to branch release-1.12
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 8fbabf6dbd41cb7b05631398b998479c090e7269
Author: Dawid Wysakowicz <dwysakow...@apache.org>
AuthorDate: Tue Dec 1 13:33:58 2020 +0100

    [FLINK-20432] Add timeouts to SQLClientSchemaRegistryITCase
    
    This closes #14275
---
 .../flink/tests/util/kafka/SQLClientSchemaRegistryITCase.java  | 10 ++++++++--
 1 file changed, 8 insertions(+), 2 deletions(-)

diff --git 
a/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SQLClientSchemaRegistryITCase.java
 
b/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SQLClientSchemaRegistryITCase.java
index f479648..61fcb1c 100644
--- 
a/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SQLClientSchemaRegistryITCase.java
+++ 
b/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SQLClientSchemaRegistryITCase.java
@@ -35,9 +35,11 @@ import org.apache.avro.SchemaBuilder;
 import org.apache.avro.generic.GenericRecordBuilder;
 import org.apache.kafka.common.serialization.StringDeserializer;
 import org.junit.Before;
+import org.junit.ClassRule;
 import org.junit.Rule;
 import org.junit.Test;
 import org.junit.experimental.categories.Category;
+import org.junit.rules.Timeout;
 import org.testcontainers.containers.KafkaContainer;
 import org.testcontainers.containers.Network;
 import org.testcontainers.utility.DockerImageName;
@@ -48,6 +50,7 @@ import java.util.Arrays;
 import java.util.Collections;
 import java.util.List;
 import java.util.UUID;
+import java.util.concurrent.TimeUnit;
 
 import static org.hamcrest.CoreMatchers.equalTo;
 import static org.junit.Assert.assertThat;
@@ -66,6 +69,9 @@ public class SQLClientSchemaRegistryITCase {
 
        public final Network network = Network.newNetwork();
 
+       @ClassRule
+       public static final Timeout TIMEOUT = new Timeout(8, TimeUnit.MINUTES);
+
        @Rule
        public final KafkaContainer kafka = new KafkaContainer(
                DockerImageName.parse("confluentinc/cp-kafka:5.5.2"))
@@ -96,7 +102,7 @@ public class SQLClientSchemaRegistryITCase {
                        10);
        }
 
-       @Test
+       @Test(timeout = 120_000)
        public void testReading() throws Exception {
                String testCategoryTopic = "test-category-" + 
UUID.randomUUID().toString();
                String testResultsTopic = "test-results-" + 
UUID.randomUUID().toString();
@@ -163,7 +169,7 @@ public class SQLClientSchemaRegistryITCase {
                ));
        }
 
-       @Test
+       @Test(timeout = 120_000)
        public void testWriting() throws Exception {
                String testUserBehaviorTopic = "test-user-behavior-" + 
UUID.randomUUID().toString();
                // Create topic test-avro