You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@hudi.apache.org by da...@apache.org on 2022/10/14 08:39:07 UTC

[hudi] branch master updated (bec05ff4c5 -> 94c068ae4f)

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 bec05ff4c5 [HUDI-5010] Fix flink hive catalog external config not work (#6923)
     add 94c068ae4f [HUDI-4948] Improve CDC Write (#6818)

No new revisions were added by this update.

Summary of changes:
 .../java/org/apache/hudi/io/HoodieCDCLogger.java   | 147 ++++++++++++---------
 .../hudi/io/HoodieMergeHandleWithChangeLog.java    |  20 ++-
 .../FlinkMergeAndReplaceHandleWithChangeLog.java   |  10 +-
 .../hudi/io/FlinkMergeHandleWithChangeLog.java     |  10 +-
 .../java/org/apache/hudi/common/fs/FSUtils.java    |   8 +-
 .../apache/hudi/common/model/HoodieWriteStat.java  |  29 ++--
 .../hudi/common/table/cdc/HoodieCDCExtractor.java  |  12 +-
 .../hudi/common/table/cdc/HoodieCDCFileSplit.java  |  28 +++-
 .../table/log/HoodieCDCLogRecordIterator.java      |  95 +++++++++----
 .../apache/hudi/common/util/CollectionUtils.java   |   4 +
 .../org/apache/hudi/common/util/JsonUtils.java     |  11 ++
 .../hudi/metadata/HoodieTableMetadataUtil.java     |   6 +-
 .../hudi/table/format/cdc/CdcInputFormat.java      |  23 +++-
 .../scala/org/apache/hudi/cdc/HoodieCDCRDD.scala   |  24 ++--
 .../hudi/functional/cdc/HoodieCDCTestBase.scala    |  30 +++--
 .../functional/cdc/TestCDCDataFrameSuite.scala     |  74 ++++++++++-
 16 files changed, 367 insertions(+), 164 deletions(-)