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;
