This is an automated email from the ASF dual-hosted git repository. fpaul pushed a commit to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 9843fa90e281e24fc9bf00018cab0ea2e1e776af 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 a76534f..a90088a 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() {
