You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@hudi.apache.org by da...@apache.org on 2026/07/30 01:21:19 UTC

(hudi) branch master updated (5727e49ba472 -> 45dcf1e81181)

This is an automated email from the ASF dual-hosted git repository.

danny0405 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git


    from 5727e49ba472 test(flink): improve sink append and partitioner test coverage (#19399)
     add 45dcf1e81181 fix(flink): improve clustering resource cleanup and coverage (#19400)

No new revisions were added by this update.

Summary of changes:
 .../collection/CloseableConcatenatingIterator.java |  11 +-
 .../util/collection/TestConcatenatingIterator.java |  22 +-
 .../hudi/sink/bulk/BulkInsertWriterHelper.java     |   4 +-
 .../hudi/sink/clustering/ClusteringOperator.java   |  74 ++--
 .../sink/clustering/TestClusteringCommitSink.java  | 252 ++++++++++++
 .../sink/clustering/TestClusteringOperator.java    | 426 +++++++++++++++++++++
 .../TestFlinkConsistentBucketUpdateStrategy.java   | 176 +++++++++
 .../compact/TestCompactionPlanSourceFunction.java  |  94 +++++
 8 files changed, 1020 insertions(+), 39 deletions(-)
 create mode 100644 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/clustering/TestClusteringCommitSink.java
 create mode 100644 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/clustering/TestClusteringOperator.java
 create mode 100644 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/clustering/update/strategy/TestFlinkConsistentBucketUpdateStrategy.java
 create mode 100644 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/compact/TestCompactionPlanSourceFunction.java