This is an automated email from the ASF dual-hosted git repository. sivabalan pushed a change to branch release-0.12.2-blockers-candidate in repository https://gitbox.apache.org/repos/asf/hudi.git
from b50dc32bcf [HUDI-5366] Closing metadata writer from within writeClient (0.12.2) (#7464) add 1061de2fce [HUDI-3661] Flink async compaction is not thread safe when use watermark (#7399) (#7465) No new revisions were added by this update. Summary of changes: .../hudi/sink/clustering/ClusteringOperator.java | 8 +++- .../{CompactFunction.java => CompactOperator.java} | 31 ++++++++++--- .../hudi/sink/compact/CompactionCommitEvent.java | 2 +- .../hudi/sink/compact/HoodieFlinkCompactor.java | 3 +- .../java/org/apache/hudi/sink/utils/Pipelines.java | 5 +- .../sink/compact/ITTestHoodieFlinkCompactor.java | 5 +- .../hudi/sink/utils/ClusteringFunctionWrapper.java | 2 +- .../hudi/sink/utils/CompactFunctionWrapper.java | 53 +++++++++++----------- .../sink/utils/StreamWriteFunctionWrapper.java | 2 +- 9 files changed, 66 insertions(+), 45 deletions(-) rename hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/{CompactFunction.java => CompactOperator.java} (82%)