(iceberg) branch main updated: Flink: fix read config of connector.iceberg.max-allowed-planning-failures (#12585)

[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 31e0f19dff Flink: fix read config of 
connector.iceberg.max-allowed-planning-failures (#12585)
31e0f19dff is described below

commit 31e0f19dff9f6c91a8d95447598fa94e70c5cbdd
Author: GuoYu <511955...@qq.com>
AuthorDate: Thu Mar 20 21:56:19 2025 +0800

    Flink: fix read config of connector.iceberg.max-allowed-planning-failures 
(#12585)
---
 .../src/main/java/org/apache/iceberg/flink/source/ScanContext.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/ScanContext.java
 
b/flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/ScanContext.java
index ab79a31739..ad8f02f9b4 100644
--- 
a/flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/ScanContext.java
+++ 
b/flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/source/ScanContext.java
@@ -557,7 +557,7 @@ public class ScanContext implements Serializable {
           .planParallelism(flinkReadConf.workerPoolSize())
           .includeColumnStats(flinkReadConf.includeColumnStats())
           .maxPlanningSnapshotCount(flinkReadConf.maxPlanningSnapshotCount())
-          .maxAllowedPlanningFailures(maxAllowedPlanningFailures)
+          
.maxAllowedPlanningFailures(flinkReadConf.maxAllowedPlanningFailures())
           .watermarkColumn(flinkReadConf.watermarkColumn())
           .watermarkColumnTimeUnit(flinkReadConf.watermarkColumnTimeUnit());
     }