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 f897e6d [HUDI-2551] Support DefaultHoodieRecordPayload for flink
(#3792)
add 2c370cb [HUDI-2556] Tweak some default config options for flink
(#3800)
No new revisions were added by this update.
Summary of changes:
.../apache/hudi/configuration/FlinkOptions.java | 26 ++++++++++++----------
.../org/apache/hudi/sink/StreamWriteFunction.java | 4 ++--
.../hudi/sink/StreamWriteOperatorCoordinator.java | 10 +++------
.../apache/hudi/sink/utils/PayloadCreation.java | 2 +-
.../apache/hudi/streamer/FlinkStreamerConfig.java | 8 +++----
.../org/apache/hudi/table/HoodieTableFactory.java | 19 +++++++++++-----
.../java/org/apache/hudi/util/StreamerUtil.java | 12 +---------
.../org/apache/hudi/sink/TestWriteCopyOnWrite.java | 4 ++--
.../apache/hudi/table/HoodieDataSourceITCase.java | 4 ++--
.../apache/hudi/table/TestHoodieTableFactory.java | 15 +++++++++++++
10 files changed, 57 insertions(+), 47 deletions(-)
