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 b6bdb46 [MINOR][HUDI-3460]Fix HoodieDataSourceITCase add fe53bd2 [HUDI-2677] Add DFS based message queue for flink writer[part3] (#4961) No new revisions were added by this update. Summary of changes: .../java/org/apache/hudi/sink/CleanFunction.java | 4 +- .../hudi/sink/StreamWriteOperatorCoordinator.java | 28 +++ .../hudi/sink/bootstrap/BootstrapOperator.java | 8 +- .../hudi/sink/bulk/BulkInsertWriteFunction.java | 18 +- .../sink/common/AbstractStreamWriteFunction.java | 11 +- .../java/org/apache/hudi/sink/meta/CkpMessage.java | 113 +++++++++++ .../org/apache/hudi/sink/meta/CkpMetadata.java | 226 +++++++++++++++++++++ .../java/org/apache/hudi/util/StreamerUtil.java | 2 +- .../org/apache/hudi/sink/TestWriteCopyOnWrite.java | 4 +- .../sink/compact/ITTestHoodieFlinkCompactor.java | 9 +- .../org/apache/hudi/sink/meta/TestCkpMetadata.java | 75 +++++++ 11 files changed, 473 insertions(+), 25 deletions(-) create mode 100644 hudi-flink/src/main/java/org/apache/hudi/sink/meta/CkpMessage.java create mode 100644 hudi-flink/src/main/java/org/apache/hudi/sink/meta/CkpMetadata.java create mode 100644 hudi-flink/src/test/java/org/apache/hudi/sink/meta/TestCkpMetadata.java