This is an automated email from the ASF dual-hosted git repository.
pvary pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg.git
from 0c46639e0e Spark 3.5: Pass FileIO on Spark's read path (#15683)
add 367a0ba3fc Flink: Add branch support to RewriteDataFiles maintenance
task (#15672)
No new revisions were added by this update.
Summary of changes:
.../flink/maintenance/api/RewriteDataFiles.java | 20 +++++++++-
.../operator/DataFileRewriteCommitter.java | 19 +++++++--
.../operator/DataFileRewritePlanner.java | 24 +++++++++---
.../operator/DataFileRewriteRunner.java | 2 +-
.../org/apache/iceberg/flink/sink/IcebergSink.java | 5 ++-
.../maintenance/api/TestRewriteDataFiles.java | 35 +++++++++++++++++
.../flink/maintenance/operator/RewriteUtil.java | 4 +-
.../operator/TestDataFileRewriteCommitter.java | 4 +-
.../operator/TestDataFileRewritePlanner.java | 45 +++++++++++++++++++++-
.../operator/TestDataFileRewriteRunner.java | 4 +-
10 files changed, 144 insertions(+), 18 deletions(-)
