This is an automated email from the ASF dual-hosted git repository.
vinoyang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git.
from c9bcb5e [HUDI-1845] Exception Throws When Sync Non-Partitioned Table
To Hive With MultiPartKeysValueExtractor (#2876)
add 6e9c5dd [HUDI-1863] Add rate limiter to Flink writer to avoid OOM for
bootstrap (#2891)
No new revisions were added by this update.
Summary of changes:
.../apache/hudi/configuration/FlinkOptions.java | 20 ++--
.../org/apache/hudi/sink/StreamWriteFunction.java | 102 +++------------------
.../sink/transform/RowDataToHoodieFunction.java | 67 +++++++++++++-
.../org/apache/hudi/source/StreamReadOperator.java | 6 +-
.../org/apache/hudi/sink/TestWriteCopyOnWrite.java | 64 +------------
.../transform/TestRowDataToHoodieFunction.java | 83 +++++++++++++++++
.../apache/hudi/table/HoodieDataSourceITCase.java | 2 +-
7 files changed, 177 insertions(+), 167 deletions(-)
create mode 100644
hudi-flink/src/test/java/org/apache/hudi/sink/transform/TestRowDataToHoodieFunction.java
