Flink: backport for fix read config of connector.iceberg.max-allowed-planning-failures (#12589)

Guosmilesmile · web-flow · commit 6779a1575966 · 2025-03-20T16:02:37.000+01:00
diff --git a/flink/v1.18/flink/src/main/java/org/apache/iceberg/flink/source/ScanContext.java b/flink/v1.18/flink/src/main/java/org/apache/iceberg/flink/source/ScanContext.java
@@ -557,7 +557,7 @@ public Builder resolveConfig(
           .planParallelism(flinkReadConf.workerPoolSize())
           .includeColumnStats(flinkReadConf.includeColumnStats())
           .maxPlanningSnapshotCount(flinkReadConf.maxPlanningSnapshotCount())
-          .maxAllowedPlanningFailures(maxAllowedPlanningFailures)
+          .maxAllowedPlanningFailures(flinkReadConf.maxAllowedPlanningFailures())
           .watermarkColumn(flinkReadConf.watermarkColumn())
           .watermarkColumnTimeUnit(flinkReadConf.watermarkColumnTimeUnit());
     }
diff --git a/flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/ScanContext.java b/flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/source/ScanContext.java
@@ -557,7 +557,7 @@ public Builder resolveConfig(
           .planParallelism(flinkReadConf.workerPoolSize())
           .includeColumnStats(flinkReadConf.includeColumnStats())
           .maxPlanningSnapshotCount(flinkReadConf.maxPlanningSnapshotCount())
-          .maxAllowedPlanningFailures(maxAllowedPlanningFailures)
+          .maxAllowedPlanningFailures(flinkReadConf.maxAllowedPlanningFailures())
           .watermarkColumn(flinkReadConf.watermarkColumn())
           .watermarkColumnTimeUnit(flinkReadConf.watermarkColumnTimeUnit());
     }

Original file line number	Diff line number	Diff line change
`@@ -557,7 +557,7 @@ public Builder resolveConfig(`
`557`	`557`	`.planParallelism(flinkReadConf.workerPoolSize())`
`558`	`558`	`.includeColumnStats(flinkReadConf.includeColumnStats())`
`559`	`559`	`.maxPlanningSnapshotCount(flinkReadConf.maxPlanningSnapshotCount())`
`560`		`- .maxAllowedPlanningFailures(maxAllowedPlanningFailures)`
	`560`	`+ .maxAllowedPlanningFailures(flinkReadConf.maxAllowedPlanningFailures())`
`561`	`561`	`.watermarkColumn(flinkReadConf.watermarkColumn())`
`562`	`562`	`.watermarkColumnTimeUnit(flinkReadConf.watermarkColumnTimeUnit());`
`563`	`563`	`}`