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 2c5a661 [HUDI-1759] Save one connection retry to hive metastore when
hiveSyncTool run with useJdbc=false (#2759)
add bfbf993 [HUDI-1878] Add max memory option for flink writer task
(#2920)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/hudi/io/HoodieMergeHandle.java | 19 ++--
.../java/org/apache/hudi/io/HoodieWriteHandle.java | 9 ++
.../java/org/apache/hudi/io/FlinkCreateHandle.java | 76 +++++++++++----
.../java/org/apache/hudi/io/FlinkMergeHandle.java | 106 ++++++++++++++-------
.../hudi/table/HoodieFlinkCopyOnWriteTable.java | 8 ++
.../apache/hudi/configuration/FlinkOptions.java | 13 +--
.../org/apache/hudi/sink/StreamWriteFunction.java | 78 +++++++++++++--
.../sink/transform/RowDataToHoodieFunction.java | 67 +------------
.../org/apache/hudi/sink/TestWriteCopyOnWrite.java | 62 ++++++++++++
.../transform/TestRowDataToHoodieFunction.java | 83 ----------------
.../sink/utils/StreamWriteFunctionWrapper.java | 1 +
11 files changed, 298 insertions(+), 224 deletions(-)
delete mode 100644
hudi-flink/src/test/java/org/apache/hudi/sink/transform/TestRowDataToHoodieFunction.java
