This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push: new 14ae6fe [hotfix][tests] Remove timout rule from KafkaTableTestBase 14ae6fe is described below commit 14ae6fee5c835871ea0145b94fbc1e8585fe78b3 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;