(iceberg) branch main updated: Flink: backport PR #9216 for disabling classloader check (#9226)

[etudenhoefner]

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

etudenhoefner 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 7b12a4171e Flink: backport PR #9216 for disabling classloader check 
(#9226)
7b12a4171e is described below

commit 7b12a4171e9e6b7829e7a66b447fc15cada151fc
Author: Steven Zhen Wu <stevenz...@gmail.com>
AuthorDate: Tue Dec 5 09:44:06 2023 -0800

    Flink: backport PR #9216 for disabling classloader check (#9226)
---
 .../flink/source/TestIcebergSourceWithWatermarkExtractor.java       | 6 +++++-
 .../flink/source/TestIcebergSourceWithWatermarkExtractor.java       | 6 +++++-
 2 files changed, 10 insertions(+), 2 deletions(-)

diff --git 
a/flink/v1.15/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceWithWatermarkExtractor.java
 
b/flink/v1.15/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceWithWatermarkExtractor.java
index 7547323871..ac4d07fa52 100644
--- 
a/flink/v1.15/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceWithWatermarkExtractor.java
+++ 
b/flink/v1.15/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceWithWatermarkExtractor.java
@@ -42,6 +42,7 @@ import 
org.apache.flink.api.common.eventtime.WatermarkStrategy;
 import org.apache.flink.api.common.typeinfo.TypeInformation;
 import org.apache.flink.api.common.typeutils.TypeSerializer;
 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;
@@ -98,7 +99,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());
 
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 0bb2eb7766..aa4b9cd79e 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
@@ -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());