[flink] branch release-1.13 updated: [hotfix][tests] Remove timout rule from KafkaTableTestBase

[sewen]

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

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


The following commit(s) were added to refs/heads/release-1.13 by this push:
     new f027863  [hotfix][tests] Remove timout rule from KafkaTableTestBase
f027863 is described below

commit f0278639491d034ef6818516c9c5233d1e69a393
Author: Stephan Ewen <se...@apache.org>
AuthorDate: Sun Apr 25 20:22:45 2021 +0200

    [hotfix][tests] Remove timout rule from KafkaTableTestBase
    
    That way, we get thread dumps from the CI infrastructure when the test 
hangs.
---
 .../flink/streaming/connectors/kafka/table/KafkaTableTestBase.java    | 4 ----
 1 file changed, 4 deletions(-)

diff --git 
a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaTableTestBase.java
 
b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaTableTestBase.java
index 97229be..c57e3c7 100644
--- 
a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaTableTestBase.java
+++ 
b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaTableTestBase.java
@@ -29,8 +29,6 @@ import org.apache.kafka.clients.admin.AdminClient;
 import org.apache.kafka.clients.admin.NewTopic;
 import org.junit.Before;
 import org.junit.ClassRule;
-import org.junit.Rule;
-import org.junit.rules.Timeout;
 import org.testcontainers.containers.KafkaContainer;
 import org.testcontainers.containers.Network;
 import org.testcontainers.utility.DockerImageName;
@@ -54,8 +52,6 @@ public abstract class KafkaTableTestBase extends 
AbstractTestBase {
                     .withNetwork(NETWORK)
                     .withNetworkAliases(INTER_CONTAINER_KAFKA_ALIAS);
 
-    @Rule public final Timeout timeoutPerTest = Timeout.seconds(30);
-
     protected StreamExecutionEnvironment env;
     protected StreamTableEnvironment tEnv;