Flink: Backport #7218 to 1.15 and 1.17

[linyanghao]

No description provided.

[linyanghao]

Checked that the flink file changed by #7218 (TestRewriteDataFilesAction.java) is consistent between 1.15, 1.16 and 1.17.

git diff --name-only --no-index flink/v1.16/flink/src/ flink/v1.17/flink/src

flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/source/RowDataFileScanTaskReader.java
flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/source/RowDataRewriter.java
flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/source/reader/AvroGenericRecordReaderFunction.java
flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/source/reader/RowDataReaderFunction.java
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkTableSource.java
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/source/reader/ReaderUtil.java
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestIcebergSourceReader.java
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/source/reader/TestRowDataReaderFunction.java
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/util/TestFlinkPackage.java

git diff --name-only --no-index flink/v1.16/flink/src/ flink/v1.15/flink/src

flink/v1.15/flink/src/main/java/org/apache/iceberg/flink/CatalogLoader.java
flink/v1.15/flink/src/main/java/org/apache/iceberg/flink/FlinkEnvironmentContext.java
flink/v1.15/flink/src/main/java/org/apache/iceberg/flink/TableLoader.java
flink/v1.15/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergFilesCommitter.java
flink/v1.15/flink/src/main/java/org/apache/iceberg/flink/source/RowDataFileScanTaskReader.java
flink/v1.15/flink/src/main/java/org/apache/iceberg/flink/source/reader/AvroGenericRecordReaderFunction.java
flink/v1.15/flink/src/main/java/org/apache/iceberg/flink/source/reader/RowDataReaderFunction.java
flink/v1.15/flink/src/test/java/org/apache/iceberg/flink/FlinkCatalogTestBase.java
flink/v1.15/flink/src/test/java/org/apache/iceberg/flink/FlinkTestBase.java
flink/v1.15/flink/src/test/java/org/apache/iceberg/flink/TestChangeLogTable.java
flink/v1.15/flink/src/test/java/org/apache/iceberg/flink/TestFlinkHiveCatalog.java
flink/v1.15/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkMergingMetrics.java
flink/v1.15/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkTableSource.java
flink/v1.15/flink/src/test/java/org/apache/iceberg/flink/util/TestFlinkPackage.java

[linyanghao]

Hi @stevenzwu . Could you take a look on this?

[stevenzwu]

thanks @linyanghao for the backport