This is an automated email from the ASF dual-hosted git repository.
vinoth pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
from 94e4d3763e7 [HUDI-9146][part3] Integrating FileGroup reader into Flink
CDC reader (#13357)
add 4284012d2b5 [HUDI-9389] Refactor table service schedule to lock
instant creation and plan generation (#13340)
No new revisions were added by this update.
Summary of changes:
azure-pipelines-20230430.yml | 4 +-
.../org/apache/hudi/async/AsyncCleanerService.java | 4 +-
.../hudi/client/BaseHoodieTableServiceClient.java | 211 +++++++++------------
.../apache/hudi/client/BaseHoodieWriteClient.java | 83 ++++----
.../metadata/HoodieBackedTableMetadataWriter.java | 6 +-
...ieBackedTableMetadataWriterTableVersionSix.java | 5 -
.../java/org/apache/hudi/table/HoodieTable.java | 10 +-
.../table/action/clean/CleanActionExecutor.java | 49 ++---
.../action/clean/CleanPlanActionExecutor.java | 54 +++---
.../client/TestBaseHoodieTableServiceClient.java | 69 ++++---
.../apache/hudi/client/WriteClientTestUtils.java | 7 +
.../org/apache/hudi/table/TestBaseHoodieTable.java | 2 +-
.../action/clean/TestCleanPlanActionExecutor.java | 75 +++++---
.../hudi/table/HoodieFlinkCopyOnWriteTable.java | 5 +-
.../hudi/table/HoodieJavaCopyOnWriteTable.java | 4 +-
.../hudi/client/TestJavaHoodieBackedMetadata.java | 46 ++---
.../hudi/table/HoodieSparkCopyOnWriteTable.java | 6 +-
.../TestHoodieClientOnCopyOnWriteStorage.java | 11 +-
.../java/org/apache/hudi/table/TestCleaner.java | 95 ++++------
.../table/action/cluster/ClusteringTestUtils.java | 10 +-
.../table/action/compact/CompactionTestBase.java | 5 +-
.../TestCopyOnWriteRollbackActionExecutor.java | 3 +-
.../java/org/apache/hudi/sink/CleanFunction.java | 4 +-
.../sink/clustering/HoodieFlinkClusteringJob.java | 9 +-
.../sink/cluster/ITTestHoodieFlinkClustering.java | 57 +++---
.../command/procedures/RunCleanProcedure.scala | 41 ++--
.../procedures/RunClusteringProcedure.scala | 8 +-
.../procedures/RunCompactionProcedure.scala | 8 +-
.../hudi/client/TestHoodieClientMultiWriter.java | 16 +-
.../TestMultiWriterWithPreferWriterIngestion.java | 36 ++--
.../hudi/client/TestTableSchemaEvolution.java | 3 +-
.../TestDataSkippingWithMORColstats.java | 2 +-
.../hudi/functional/TestHoodieBackedMetadata.java | 68 +++----
.../hudi/table/TestHoodieMergeOnReadTable.java | 3 +-
.../table/action/compact/TestAsyncCompaction.java | 3 +-
.../table/action/compact/TestHoodieCompactor.java | 13 +-
.../TestMergeOnReadRollbackActionExecutor.java | 3 +-
...HoodieSparkMergeOnReadTableIncrementalRead.java | 3 +-
.../TestHoodieSparkMergeOnReadTableRollback.java | 13 +-
.../hudi/functional/TestSevenToEightUpgrade.scala | 3 +-
.../sql/hudi/ddl/TestAlterTableDropPartition.scala | 12 +-
.../spark/sql/hudi/dml/TestInsertTable.scala | 3 +-
.../spark/sql/hudi/dml/TestUpdateTable.scala | 3 +-
.../hudi/procedure/TestClusteringProcedure.scala | 9 +-
.../procedure/TestShowFileStatusProcedure.scala | 12 +-
.../apache/hudi/utilities/HoodieClusteringJob.java | 4 -
.../org/apache/hudi/utilities/HoodieCompactor.java | 8 +-
47 files changed, 492 insertions(+), 616 deletions(-)
