This is an automated email from the ASF dual-hosted git repository. fpaul pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 55a0bada0a1afbadd2978934ef40df3208408cc2 Author: Qingsheng Ren <[email protected]> AuthorDate: Thu Dec 16 16:03:55 2021 +0800 [FLINK-25263][e2e/kafka] Re-enable temporarily disabled KafkaSourceE2ECase --- .../test/java/org/apache/flink/tests/util/kafka/KafkaSourceE2ECase.java | 2 -- 1 file changed, 2 deletions(-) diff --git a/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/KafkaSourceE2ECase.java b/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/KafkaSourceE2ECase.java index ac43d9e..9f5e9f7 100644 --- a/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/KafkaSourceE2ECase.java +++ b/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/KafkaSourceE2ECase.java @@ -29,12 +29,10 @@ import org.apache.flink.tests.util.TestUtils; import org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment; import org.apache.flink.util.DockerImageVersions; -import org.junit.jupiter.api.Disabled; import org.testcontainers.containers.KafkaContainer; import org.testcontainers.utility.DockerImageName; /** Kafka E2E test based on connector testing framework. */ -@Disabled("FLINK-25263") public class KafkaSourceE2ECase extends SourceTestSuiteBase<String> { private static final String KAFKA_HOSTNAME = "kafka";
