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 634163a [HUDI-2145] Create new bucket when NewFileAssignState filled
(#3258)
add 858e84b [HUDI-2198] Clean and reset the bootstrap events for
coordinator when task failover (#3304)
No new revisions were added by this update.
Summary of changes:
.../apache/hudi/client/HoodieFlinkWriteClient.java | 2 +-
.../org/apache/hudi/sink/StreamWriteFunction.java | 2 ++
.../hudi/sink/StreamWriteOperatorCoordinator.java | 8 +++---
.../sink/partitioner/BucketAssignFunction.java | 7 ++---
.../org/apache/hudi/sink/TestWriteCopyOnWrite.java | 23 ++++++++++++++++
.../sink/utils/StreamWriteFunctionWrapper.java | 31 +++++++++++++++-------
6 files changed, 57 insertions(+), 16 deletions(-)
