[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.
diff --git a/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java b/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java
index cdcbe3b..7689fba 100644
--- a/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java
+++ b/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.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.TimeoutException;
import org.junit.Assert;
import org.junit.Before;
-import org.junit.Rule;
import javax.annotation.Nullable;
import javax.management.MBeanServer;
@@ -135,8 +133,6 @@
public abstract class KafkaConsumerTestBase extends KafkaTestBaseWithFlink {
protected final boolean useNewSource;
- @Rule public RetryRule retryRule = new RetryRule();
-
private ClusterClient<?> client;
protected KafkaConsumerTestBase() {
