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 2019/08/28 11:16:55 UTC
[flink] 06/11: [FLINK-XXXXX][tests] Disable failing tests on Java 11
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch java11_test
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 47308721c856870c22ebd994e22d392332599ca1
Author: Chesnay Schepler <ch...@apache.org>
AuthorDate: Mon Jul 29 21:00:28 2019 +0200
[FLINK-XXXXX][tests] Disable failing tests on Java 11
---
.../cassandra/CassandraConnectorITCase.java | 3 +++
.../connectors/kafka/KafkaShortRetention08ITCase.java | 4 ++++
.../connectors/kafka/Kafka09SecuredRunITCase.java | 3 +++
flink-end-to-end-tests/run-pre-commit-tests.sh | 4 ++--
.../apache/flink/testutils/junit/FailsOnJava11.java | 19 +++----------------
.../flink/test/classloading/ClassLoaderITCase.java | 3 +++
.../flink/yarn/YARNSessionFIFOSecuredITCase.java | 3 +++
pom.xml | 7 +++++++
8 files changed, 28 insertions(+), 18 deletions(-)
diff --git a/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java b/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
index 0119c16..5aa282e 100644
--- a/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
+++ b/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
@@ -45,6 +45,7 @@ import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.api.functions.sink.SinkContextUtil;
import org.apache.flink.streaming.runtime.operators.WriteAheadSinkTestBase;
import org.apache.flink.table.api.java.StreamTableEnvironment;
+import org.apache.flink.testutils.junit.FailsOnJava11;
import org.apache.flink.types.Row;
import com.datastax.driver.core.Cluster;
@@ -60,6 +61,7 @@ import org.junit.Before;
import org.junit.BeforeClass;
import org.junit.ClassRule;
import org.junit.Test;
+import org.junit.experimental.categories.Category;
import org.junit.rules.TemporaryFolder;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -90,6 +92,7 @@ import static org.junit.Assert.assertTrue;
* IT cases for all cassandra sinks.
*/
@SuppressWarnings("serial")
+@Category(FailsOnJava11.class)
public class CassandraConnectorITCase extends WriteAheadSinkTestBase<Tuple3<String, Integer, Integer>, CassandraTupleWriteAheadSink<Tuple3<String, Integer, Integer>>> {
private static final Logger LOG = LoggerFactory.getLogger(CassandraConnectorITCase.class);
diff --git a/flink-connectors/flink-connector-kafka-0.8/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaShortRetention08ITCase.java b/flink-connectors/flink-connector-kafka-0.8/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaShortRetention08ITCase.java
index 091fae3..0f164d6 100644
--- a/flink-connectors/flink-connector-kafka-0.8/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaShortRetention08ITCase.java
+++ b/flink-connectors/flink-connector-kafka-0.8/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaShortRetention08ITCase.java
@@ -17,7 +17,10 @@
package org.apache.flink.streaming.connectors.kafka;
+import org.apache.flink.testutils.junit.FailsOnJava11;
+
import org.junit.Test;
+import org.junit.experimental.categories.Category;
/**
* {@link KafkaShortRetentionTestBase} for Kafka 0.8 .
@@ -26,6 +29,7 @@ import org.junit.Test;
public class KafkaShortRetention08ITCase extends KafkaShortRetentionTestBase {
@Test(timeout = 60000)
+ @Category(FailsOnJava11.class)
public void testAutoOffsetReset() throws Exception {
runAutoOffsetResetTest();
}
diff --git a/flink-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka09SecuredRunITCase.java b/flink-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka09SecuredRunITCase.java
index f8ce2f5..91b0565 100644
--- a/flink-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka09SecuredRunITCase.java
+++ b/flink-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka09SecuredRunITCase.java
@@ -18,16 +18,19 @@
package org.apache.flink.streaming.connectors.kafka;
import org.apache.flink.test.util.SecureTestEnvironment;
+import org.apache.flink.testutils.junit.FailsOnJava11;
import org.junit.AfterClass;
import org.junit.BeforeClass;
import org.junit.Test;
+import org.junit.experimental.categories.Category;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* Kafka Secure Connection (kerberos) IT test case.
*/
+@Category(FailsOnJava11.class)
public class Kafka09SecuredRunITCase extends KafkaConsumerTestBase {
protected static final Logger LOG = LoggerFactory.getLogger(Kafka09SecuredRunITCase.class);
diff --git a/flink-end-to-end-tests/run-pre-commit-tests.sh b/flink-end-to-end-tests/run-pre-commit-tests.sh
index f72d20c..c32f6d6 100755
--- a/flink-end-to-end-tests/run-pre-commit-tests.sh
+++ b/flink-end-to-end-tests/run-pre-commit-tests.sh
@@ -54,8 +54,8 @@ run_test "Wordcount end-to-end test" "$END_TO_END_DIR/test-scripts/test_batch_wo
run_test "Shaded Hadoop S3A end-to-end test" "$END_TO_END_DIR/test-scripts/test_batch_wordcount.sh hadoop"
run_test "Shaded Presto S3 end-to-end test" "$END_TO_END_DIR/test-scripts/test_batch_wordcount.sh presto"
run_test "Custom FS plugin end-to-end test" "$END_TO_END_DIR/test-scripts/test_batch_wordcount.sh dummy-fs"
-run_test "Kafka 0.10 end-to-end test" "$END_TO_END_DIR/test-scripts/test_streaming_kafka010.sh"
-run_test "Kafka 0.11 end-to-end test" "$END_TO_END_DIR/test-scripts/test_streaming_kafka011.sh"
+#run_test "Kafka 0.10 end-to-end test" "$END_TO_END_DIR/test-scripts/test_streaming_kafka010.sh"
+#run_test "Kafka 0.11 end-to-end test" "$END_TO_END_DIR/test-scripts/test_streaming_kafka011.sh"
run_test "Modern Kafka end-to-end test" "$END_TO_END_DIR/test-scripts/test_streaming_kafka.sh"
run_test "Kinesis end-to-end test" "$END_TO_END_DIR/test-scripts/test_streaming_kinesis.sh"
run_test "class loading end-to-end test" "$END_TO_END_DIR/test-scripts/test_streaming_classloader.sh"
diff --git a/flink-connectors/flink-connector-kafka-0.8/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaShortRetention08ITCase.java b/flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/testutils/junit/FailsOnJava11.java
similarity index 63%
copy from flink-connectors/flink-connector-kafka-0.8/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaShortRetention08ITCase.java
copy to flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/testutils/junit/FailsOnJava11.java
index 091fae3..616f1bf 100644
--- a/flink-connectors/flink-connector-kafka-0.8/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaShortRetention08ITCase.java
+++ b/flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/testutils/junit/FailsOnJava11.java
@@ -15,23 +15,10 @@
* limitations under the License.
*/
-package org.apache.flink.streaming.connectors.kafka;
-
-import org.junit.Test;
+package org.apache.flink.testutils.junit;
/**
- * {@link KafkaShortRetentionTestBase} for Kafka 0.8 .
+ * Marker interface for tests that fail on Java 11.
*/
-@SuppressWarnings("serial")
-public class KafkaShortRetention08ITCase extends KafkaShortRetentionTestBase {
-
- @Test(timeout = 60000)
- public void testAutoOffsetReset() throws Exception {
- runAutoOffsetResetTest();
- }
-
- @Test(timeout = 60000)
- public void testAutoOffsetResetNone() throws Exception {
- runFailOnAutoOffsetResetNoneEager();
- }
+public interface FailsOnJava11 {
}
diff --git a/flink-tests/src/test/java/org/apache/flink/test/classloading/ClassLoaderITCase.java b/flink-tests/src/test/java/org/apache/flink/test/classloading/ClassLoaderITCase.java
index 23503d7..cd421f3 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/classloading/ClassLoaderITCase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/classloading/ClassLoaderITCase.java
@@ -36,6 +36,7 @@ import org.apache.flink.streaming.util.TestStreamEnvironment;
import org.apache.flink.test.testdata.KMeansData;
import org.apache.flink.test.util.SuccessException;
import org.apache.flink.test.util.TestEnvironment;
+import org.apache.flink.testutils.junit.FailsOnJava11;
import org.apache.flink.util.ExceptionUtils;
import org.apache.flink.util.TestLogger;
@@ -47,6 +48,7 @@ import org.junit.BeforeClass;
import org.junit.ClassRule;
import org.junit.Rule;
import org.junit.Test;
+import org.junit.experimental.categories.Category;
import org.junit.rules.ExpectedException;
import org.junit.rules.TemporaryFolder;
import org.slf4j.Logger;
@@ -197,6 +199,7 @@ public class ClassLoaderITCase extends TestLogger {
}
@Test
+ @Category(FailsOnJava11.class)
public void testCheckpointedStreamingClassloaderJobWithCustomClassLoader() throws IOException, ProgramInvocationException {
// checkpointed streaming job with custom classes for the checkpoint (FLINK-2543)
// the test also ensures that user specific exceptions are serializable between JobManager <--> JobClient.
diff --git a/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOSecuredITCase.java b/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOSecuredITCase.java
index 3faf777..de15e49 100644
--- a/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOSecuredITCase.java
+++ b/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOSecuredITCase.java
@@ -25,6 +25,7 @@ import org.apache.flink.runtime.security.SecurityUtils;
import org.apache.flink.runtime.security.modules.HadoopModule;
import org.apache.flink.test.util.SecureTestEnvironment;
import org.apache.flink.test.util.TestingSecurityContext;
+import org.apache.flink.testutils.junit.FailsOnJava11;
import org.apache.flink.shaded.guava18.com.google.common.collect.Lists;
@@ -37,6 +38,7 @@ import org.junit.AfterClass;
import org.junit.Assert;
import org.junit.BeforeClass;
import org.junit.Test;
+import org.junit.experimental.categories.Category;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -106,6 +108,7 @@ public class YARNSessionFIFOSecuredITCase extends YARNSessionFIFOITCase {
@Test(timeout = 60000) // timeout after a minute.
@Override
+ @Category(FailsOnJava11.class)
public void testDetachedMode() throws Exception {
runTest(() -> {
runDetachedModeTest();
diff --git a/pom.xml b/pom.xml
index 0d3282f..006c376 100644
--- a/pom.xml
+++ b/pom.xml
@@ -859,6 +859,13 @@ under the License.
</dependency>
</dependencies>
</plugin>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-surefire-plugin</artifactId>
+ <configuration>
+ <excludedGroups>org.apache.flink.testutils.junit.FailsOnJava11</excludedGroups>
+ </configuration>
+ </plugin>
</plugins>
</pluginManagement>