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

Posted to commits@hudi.apache.org by vi...@apache.org on 2021/06/18 01:35:25 UTC

[hudi] branch master updated (b9e28e5 -> aa6342c)

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 b9e28e5  [HUDI-2033] ClassCastException Throw When PreCombineField Is String Type (#3099)
     add aa6342c  [HUDI-2036] Move the compaction plan scheduling out of flink writer coordinator (#3101)

No new revisions were added by this update.

Summary of changes:
 .../FlinkScheduleCompactionActionExecutor.java     |  40 --------
 .../hudi/sink/StreamWriteOperatorCoordinator.java  |  10 --
 .../apache/hudi/sink/compact/CompactFunction.java  |  28 ++++--
 .../hudi/sink/compact/CompactionCommitSink.java    |   3 +-
 .../hudi/sink/compact/CompactionPlanOperator.java  |  44 ++++-----
 .../sink/compact/CompactionPlanSourceFunction.java |   3 +-
 .../hudi/sink/compact/FlinkCompactionConfig.java   |   2 +
 .../hudi/sink/compact/HoodieFlinkCompactor.java    |  36 ++------
 .../hudi/sink/compact/NonKeyedCompactFunction.java | 102 ---------------------
 .../apache/hudi/streamer/HoodieFlinkStreamer.java  |   6 +-
 .../org/apache/hudi/table/HoodieTableSink.java     |   7 +-
 .../java/org/apache/hudi/util/CompactionUtil.java  |  51 +++++++----
 .../java/org/apache/hudi/util/StreamerUtil.java    |  14 +--
 .../org/apache/hudi/sink/StreamWriteITCase.java    |  76 +++++++--------
 .../org/apache/hudi/sink/TestWriteMergeOnRead.java |   7 ++
 .../sink/utils/StreamWriteFunctionWrapper.java     |  18 +++-
 16 files changed, 156 insertions(+), 291 deletions(-)
 delete mode 100644 hudi-flink/src/main/java/org/apache/hudi/sink/compact/NonKeyedCompactFunction.java