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 2c1e259 [HUDI-2651] Sync all the missing sql options for
HoodieFlinkStreamer (#3903)
add f67da0c [HUDI-2686] Proccess record after all bootstrap operator
ready (#3925)
No new revisions were added by this update.
Summary of changes:
.../hudi/sink/bootstrap/BootstrapOperator.java | 29 ++++++++++++-
.../aggregate/BootstrapAccumulator.java} | 35 ++++++++-------
.../bootstrap/aggregate/BootstrapAggFunction.java | 50 ++++++++++++++++++++++
.../bootstrap/batch/BatchBootstrapOperator.java | 4 +-
4 files changed, 99 insertions(+), 19 deletions(-)
copy hudi-flink/src/main/java/org/apache/hudi/sink/{event/CommitAckEvent.java
=> bootstrap/aggregate/BootstrapAccumulator.java} (56%)
create mode 100644
hudi-flink/src/main/java/org/apache/hudi/sink/bootstrap/aggregate/BootstrapAggFunction.java
