This is an automated email from the ASF dual-hosted git repository.
wangxianghu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git.
from 6a71412 [HUDI-2116] Support batch synchronization of partition datas
to hive metastore to avoid oom problem (#3209)
add 98ec017 [HUDI-2126] The coordinator send events to write function
when there are no data for the checkpoint (#3219)
No new revisions were added by this update.
Summary of changes:
.../org/apache/hudi/sink/StreamWriteFunction.java | 25 +++++++++++++++-------
.../org/apache/hudi/sink/StreamWriteOperator.java | 4 ++--
.../hudi/sink/StreamWriteOperatorCoordinator.java | 25 ++++++++++++++++++++++
.../IndexRecord.java => event/CommitAckEvent.java} | 17 ++++++++-------
4 files changed, 53 insertions(+), 18 deletions(-)
copy hudi-flink/src/main/java/org/apache/hudi/sink/{bootstrap/IndexRecord.java
=> event/CommitAckEvent.java} (70%)
