This is an automated email from the ASF dual-hosted git repository. fpaul pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 0d9aed95ad0618ef190fd219251be0e068320a44 Author: Fabian Paul <[email protected]> AuthorDate: Wed Dec 1 14:13:34 2021 +0100 [FLINK-25134][test] Remove unused RetryRule from KafkaConsumerTestBase Before this commit the RetryRule actually prevented retries of tests inheriting from KafkaConsumerTestBase. Now, the retries are handled by KafkaTestBase and all subclasses have the same retry behaviour. --- .../flink/streaming/connectors/kafka/KafkaConsumerTestBase.java | 4 ---- 1 file changed, 4 deletions(-) diff --git a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java index c231517..becb303 100644 --- a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java +++ b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java @@ -77,7 +77,6 @@ import org.apache.flink.streaming.util.serialization.KeyedSerializationSchema; import org.apache.flink.streaming.util.serialization.TypeInformationKeyValueSerializationSchema; import org.apache.flink.test.util.SuccessException; import org.apache.flink.testutils.junit.RetryOnException; -import org.apache.flink.testutils.junit.RetryRule; import org.apache.flink.util.Collector; import org.apache.flink.util.ExceptionUtils; @@ -94,7 +93,6 @@ import org.apache.kafka.common.errors.NotLeaderForPartitionException; import org.apache.kafka.common.errors.TimeoutException; import org.junit.Assert; import org.junit.Before; -import org.junit.Rule; import javax.annotation.Nullable; import javax.management.MBeanServer; @@ -133,8 +131,6 @@ import static org.junit.Assert.fail; public abstract class KafkaConsumerTestBase extends KafkaTestBaseWithFlink { protected final boolean useNewSource; - @Rule public RetryRule retryRule = new RetryRule(); - private ClusterClient<?> client; protected KafkaConsumerTestBase() {
