You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2022/08/04 11:27:42 UTC
[flink] branch master updated: [FLINK-25252][kafka] Enabling Kafka tests on Java 11
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 75a66f921c9 [FLINK-25252][kafka] Enabling Kafka tests on Java 11
75a66f921c9 is described below
commit 75a66f921c94ebc5686a3bacf741fee2bdfe6dd6
Author: MartijnVisser <ma...@apache.org>
AuthorDate: Thu Aug 4 13:27:31 2022 +0200
[FLINK-25252][kafka] Enabling Kafka tests on Java 11
---
.../java/org/apache/flink/tests/util/kafka/SQLClientKafkaITCase.java | 3 ---
.../test/java/org/apache/flink/tests/util/kafka/SmokeKafkaITCase.java | 3 ---
2 files changed, 6 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/SQLClientKafkaITCase.java b/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SQLClientKafkaITCase.java
index eee3c478e36..f1d95da8cc6 100644
--- a/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SQLClientKafkaITCase.java
+++ b/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SQLClientKafkaITCase.java
@@ -27,7 +27,6 @@ import org.apache.flink.tests.util.flink.ClusterController;
import org.apache.flink.tests.util.flink.FlinkResource;
import org.apache.flink.tests.util.flink.FlinkResourceSetup;
import org.apache.flink.tests.util.flink.LocalStandaloneFlinkResourceFactory;
-import org.apache.flink.testutils.junit.FailsOnJava11;
import org.apache.flink.util.TestLogger;
import org.apache.commons.lang3.StringUtils;
@@ -37,7 +36,6 @@ import org.junit.ClassRule;
import org.junit.Ignore;
import org.junit.Rule;
import org.junit.Test;
-import org.junit.experimental.categories.Category;
import org.junit.rules.TemporaryFolder;
import org.junit.runner.RunWith;
import org.junit.runners.Parameterized;
@@ -65,7 +63,6 @@ import static org.junit.Assert.assertThat;
/** End-to-end test for the kafka SQL connectors. */
@RunWith(Parameterized.class)
-@Category(value = {FailsOnJava11.class})
@Ignore("FLINK-21796")
public class SQLClientKafkaITCase extends TestLogger {
diff --git a/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SmokeKafkaITCase.java b/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SmokeKafkaITCase.java
index a84e5d2c855..29fbdf82b35 100644
--- a/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SmokeKafkaITCase.java
+++ b/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SmokeKafkaITCase.java
@@ -27,7 +27,6 @@ import org.apache.flink.connector.testframe.container.TestcontainersSettings;
import org.apache.flink.streaming.api.environment.ExecutionCheckpointingOptions;
import org.apache.flink.test.util.JobSubmission;
import org.apache.flink.tests.util.TestUtils;
-import org.apache.flink.testutils.junit.FailsOnJava11;
import org.apache.flink.util.TestLoggerExtension;
import org.apache.flink.shaded.guava30.com.google.common.collect.Lists;
@@ -43,7 +42,6 @@ import org.apache.kafka.common.serialization.IntegerDeserializer;
import org.apache.kafka.common.serialization.IntegerSerializer;
import org.apache.kafka.common.serialization.VoidDeserializer;
import org.apache.kafka.common.serialization.VoidSerializer;
-import org.junit.experimental.categories.Category;
import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.Test;
@@ -70,7 +68,6 @@ import static org.apache.flink.util.DockerImageVersions.KAFKA;
import static org.assertj.core.api.Assertions.assertThat;
/** smoke test for the kafka connectors. */
-@Category(value = {FailsOnJava11.class})
@ExtendWith({TestLoggerExtension.class})
@Testcontainers
public class SmokeKafkaITCase {