You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iceberg.apache.org by et...@apache.org on 2023/12/05 17:44:12 UTC
(iceberg) branch main updated: Flink: backport PR #9216 for disabling classloader check (#9226)
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 <st...@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());