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
