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 60758b3 [HUDI-2227] Only sync hive meta on successful commit for
flink batch writer (#3351)
add 00cd35f [HUDI-2215] Add rateLimiter when Flink writes to hudi. (#3338)
No new revisions were added by this update.
Summary of changes:
.../apache/hudi/configuration/FlinkOptions.java | 6 +++
.../sink/transform/RowDataToHoodieFunction.java | 2 +-
.../RowDataToHoodieFunctionWithRateLimit.java | 61 ++++++++++++++++++++++
...nsformer.java => RowDataToHoodieFunctions.java} | 24 ++++++---
.../apache/hudi/streamer/HoodieFlinkStreamer.java | 5 +-
.../org/apache/hudi/table/HoodieTableSink.java | 4 +-
6 files changed, 90 insertions(+), 12 deletions(-)
create mode 100644
hudi-flink/src/main/java/org/apache/hudi/sink/transform/RowDataToHoodieFunctionWithRateLimit.java
copy hudi-flink/src/main/java/org/apache/hudi/sink/transform/{Transformer.java
=> RowDataToHoodieFunctions.java} (53%)
