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
