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