(iceberg) branch main updated: Flink: fix flaky test that might fail due to classloader check (#9216)

[pvary]

This is an automated email from the ASF dual-hosted git repository.

pvary pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg.git


The following commit(s) were added to refs/heads/main by this push:
     new cbd33a6f62 Flink: fix flaky test that might fail due to classloader 
check (#9216)
cbd33a6f62 is described below

commit cbd33a6f626161bd1a4f0894a9dd4d96aed1a35b
Author: Steven Zhen Wu <stevenz...@gmail.com>
AuthorDate: Tue Dec 5 04:08:48 2023 -0800

    Flink: fix flaky test that might fail due to classloader check (#9216)
---
 .../flink/source/TestIcebergSourceWithWatermarkExtractor.java       | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

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 0bb2eb7766..aa4b9cd79e 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
@@ -40,6 +40,7 @@ import 
org.apache.flink.api.common.eventtime.SerializableTimestampAssigner;
 import org.apache.flink.api.common.eventtime.WatermarkStrategy;
 import org.apache.flink.api.common.typeinfo.TypeInformation;
 import org.apache.flink.configuration.Configuration;
+import org.apache.flink.configuration.CoreOptions;
 import org.apache.flink.core.execution.JobClient;
 import org.apache.flink.metrics.Gauge;
 import org.apache.flink.runtime.metrics.MetricNames;
@@ -92,7 +93,10 @@ public class TestIcebergSourceWithWatermarkExtractor 
implements Serializable {
               .setNumberTaskManagers(1)
               .setNumberSlotsPerTaskManager(PARALLELISM)
               .setRpcServiceSharing(RpcServiceSharing.DEDICATED)
-              .setConfiguration(reporter.addToConfiguration(new 
Configuration()))
+              .setConfiguration(
+                  reporter.addToConfiguration(
+                      // disable classloader check as Avro may cache class in 
the serializers.
+                      new 
Configuration().set(CoreOptions.CHECK_LEAKED_CLASSLOADER, false)))
               .withHaLeadershipControl()
               .build());