From 46e07494fcd4452975d609887a5eded0ffcba7da Mon Sep 17 00:00:00 2001 From: manuzhang Date: Thu, 4 Jan 2024 16:54:55 +0800 Subject: [PATCH] Flink: Disable classloader check in TestIcebergSourceWithWatermarkExtractor to fix flakiness --- .../flink/source/TestIcebergSourceWithWatermarkExtractor.java | 2 ++ .../flink/source/TestIcebergSourceWithWatermarkExtractor.java | 2 ++ .../flink/source/TestIcebergSourceWithWatermarkExtractor.java | 2 ++ 3 files changed, 6 insertions(+) diff --git a/flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceWithWatermarkExtractor.java b/flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceWithWatermarkExtractor.java index 7428d30f4261..d9eaf86691c0 100644 --- a/flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceWithWatermarkExtractor.java +++ b/flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceWithWatermarkExtractor.java @@ -19,6 +19,7 @@ package org.apache.iceberg.flink.source; import static org.apache.flink.connector.testframe.utils.ConnectorTestConstants.DEFAULT_COLLECT_DATA_TIMEOUT; +import static org.apache.iceberg.flink.MiniClusterResource.DISABLE_CLASSLOADER_CHECK_CONFIG; import static org.assertj.core.api.AssertionsForClassTypes.assertThat; import java.io.Serializable; @@ -95,6 +96,7 @@ public class TestIcebergSourceWithWatermarkExtractor implements Serializable { .setNumberSlotsPerTaskManager(PARALLELISM) .setRpcServiceSharing(RpcServiceSharing.DEDICATED) .setConfiguration(reporter.addToConfiguration(new Configuration())) + .setConfiguration(DISABLE_CLASSLOADER_CHECK_CONFIG) .withHaLeadershipControl() .build()); diff --git a/flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceWithWatermarkExtractor.java b/flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceWithWatermarkExtractor.java index c4070212df92..ce5bfcab094b 100644 --- a/flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceWithWatermarkExtractor.java +++ b/flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceWithWatermarkExtractor.java @@ -19,6 +19,7 @@ package org.apache.iceberg.flink.source; import static org.apache.flink.connector.testframe.utils.ConnectorTestConstants.DEFAULT_COLLECT_DATA_TIMEOUT; +import static org.apache.iceberg.flink.MiniClusterResource.DISABLE_CLASSLOADER_CHECK_CONFIG; import static org.assertj.core.api.AssertionsForClassTypes.assertThat; import java.io.Serializable; @@ -98,6 +99,7 @@ public class TestIcebergSourceWithWatermarkExtractor implements Serializable { .setConfiguration( reporter.addToConfiguration( new Configuration().set(PipelineOptions.ALLOW_UNALIGNED_SOURCE_SPLITS, true))) + .setConfiguration(DISABLE_CLASSLOADER_CHECK_CONFIG) .withHaLeadershipControl() .build()); diff --git a/flink/v1.18/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceWithWatermarkExtractor.java b/flink/v1.18/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceWithWatermarkExtractor.java index 2ef8f79aa372..562ce986b759 100644 --- a/flink/v1.18/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceWithWatermarkExtractor.java +++ b/flink/v1.18/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceWithWatermarkExtractor.java @@ -19,6 +19,7 @@ package org.apache.iceberg.flink.source; import static org.apache.flink.connector.testframe.utils.ConnectorTestConstants.DEFAULT_COLLECT_DATA_TIMEOUT; +import static org.apache.iceberg.flink.MiniClusterResource.DISABLE_CLASSLOADER_CHECK_CONFIG; import static org.assertj.core.api.AssertionsForClassTypes.assertThat; import java.io.Serializable; @@ -95,6 +96,7 @@ public class TestIcebergSourceWithWatermarkExtractor implements Serializable { .setNumberSlotsPerTaskManager(PARALLELISM) .setRpcServiceSharing(RpcServiceSharing.DEDICATED) .setConfiguration(reporter.addToConfiguration(new Configuration())) + .setConfiguration(DISABLE_CLASSLOADER_CHECK_CONFIG) .withHaLeadershipControl() .build());