diff --git a/flink/v1.12/flink/src/main/java/org/apache/iceberg/flink/source/RowDataFileScanTaskReader.java b/flink/v1.12/flink/src/main/java/org/apache/iceberg/flink/source/RowDataFileScanTaskReader.java index 43c9ce1eefae..b71f2b0fafe5 100644 --- a/flink/v1.12/flink/src/main/java/org/apache/iceberg/flink/source/RowDataFileScanTaskReader.java +++ b/flink/v1.12/flink/src/main/java/org/apache/iceberg/flink/source/RowDataFileScanTaskReader.java @@ -172,7 +172,7 @@ private static class FlinkDeleteFilter extends DeleteFilter { FlinkDeleteFilter(FileScanTask task, Schema tableSchema, Schema requestedSchema, InputFilesDecryptor inputFilesDecryptor) { - super(task, tableSchema, requestedSchema); + super(task.file().path().toString(), task.deletes(), tableSchema, requestedSchema); this.requiredRowType = FlinkSchemaUtil.convert(requiredSchema()); this.asStructLike = new RowDataWrapper(requiredRowType, requiredSchema().asStruct()); this.inputFilesDecryptor = inputFilesDecryptor; diff --git a/flink/v1.13/flink/src/main/java/org/apache/iceberg/flink/source/RowDataFileScanTaskReader.java b/flink/v1.13/flink/src/main/java/org/apache/iceberg/flink/source/RowDataFileScanTaskReader.java index 43c9ce1eefae..b71f2b0fafe5 100644 --- a/flink/v1.13/flink/src/main/java/org/apache/iceberg/flink/source/RowDataFileScanTaskReader.java +++ b/flink/v1.13/flink/src/main/java/org/apache/iceberg/flink/source/RowDataFileScanTaskReader.java @@ -172,7 +172,7 @@ private static class FlinkDeleteFilter extends DeleteFilter { FlinkDeleteFilter(FileScanTask task, Schema tableSchema, Schema requestedSchema, InputFilesDecryptor inputFilesDecryptor) { - super(task, tableSchema, requestedSchema); + super(task.file().path().toString(), task.deletes(), tableSchema, requestedSchema); this.requiredRowType = FlinkSchemaUtil.convert(requiredSchema()); this.asStructLike = new RowDataWrapper(requiredRowType, requiredSchema().asStruct()); this.inputFilesDecryptor = inputFilesDecryptor; diff --git a/spark/v2.4/spark/src/main/java/org/apache/iceberg/spark/source/RowDataReader.java b/spark/v2.4/spark/src/main/java/org/apache/iceberg/spark/source/RowDataReader.java index 8770e17aa015..4f5962494feb 100644 --- a/spark/v2.4/spark/src/main/java/org/apache/iceberg/spark/source/RowDataReader.java +++ b/spark/v2.4/spark/src/main/java/org/apache/iceberg/spark/source/RowDataReader.java @@ -182,7 +182,7 @@ protected class SparkDeleteFilter extends DeleteFilter { private final InternalRowWrapper asStructLike; SparkDeleteFilter(FileScanTask task, Schema tableSchema, Schema requestedSchema) { - super(task, tableSchema, requestedSchema); + super(task.file().path().toString(), task.deletes(), tableSchema, requestedSchema); this.asStructLike = new InternalRowWrapper(SparkSchemaUtil.convert(requiredSchema())); } diff --git a/spark/v3.0/spark/src/main/java/org/apache/iceberg/spark/source/RowDataReader.java b/spark/v3.0/spark/src/main/java/org/apache/iceberg/spark/source/RowDataReader.java index 8770e17aa015..4f5962494feb 100644 --- a/spark/v3.0/spark/src/main/java/org/apache/iceberg/spark/source/RowDataReader.java +++ b/spark/v3.0/spark/src/main/java/org/apache/iceberg/spark/source/RowDataReader.java @@ -182,7 +182,7 @@ protected class SparkDeleteFilter extends DeleteFilter { private final InternalRowWrapper asStructLike; SparkDeleteFilter(FileScanTask task, Schema tableSchema, Schema requestedSchema) { - super(task, tableSchema, requestedSchema); + super(task.file().path().toString(), task.deletes(), tableSchema, requestedSchema); this.asStructLike = new InternalRowWrapper(SparkSchemaUtil.convert(requiredSchema())); } diff --git a/spark/v3.1/spark/src/main/java/org/apache/iceberg/spark/source/RowDataReader.java b/spark/v3.1/spark/src/main/java/org/apache/iceberg/spark/source/RowDataReader.java index 8770e17aa015..4f5962494feb 100644 --- a/spark/v3.1/spark/src/main/java/org/apache/iceberg/spark/source/RowDataReader.java +++ b/spark/v3.1/spark/src/main/java/org/apache/iceberg/spark/source/RowDataReader.java @@ -182,7 +182,7 @@ protected class SparkDeleteFilter extends DeleteFilter { private final InternalRowWrapper asStructLike; SparkDeleteFilter(FileScanTask task, Schema tableSchema, Schema requestedSchema) { - super(task, tableSchema, requestedSchema); + super(task.file().path().toString(), task.deletes(), tableSchema, requestedSchema); this.asStructLike = new InternalRowWrapper(SparkSchemaUtil.convert(requiredSchema())); }