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;