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 92a3c45 [HUDI-2654] Schedules the compaction from earliest for flink
(#3891)
add 87c6f9c [HUDI-2654] Add compaction failed event(part2) (#3896)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/hudi/sink/CleanFunction.java | 3 +-
.../hudi/sink/StreamWriteOperatorCoordinator.java | 11 +--
.../apache/hudi/sink/compact/CompactFunction.java | 3 +-
.../hudi/sink/compact/CompactionCommitEvent.java | 15 ++++
.../hudi/sink/compact/CompactionCommitSink.java | 13 ++++
.../hudi/sink/compact/CompactionPlanOperator.java | 14 ++--
.../hudi/sink/utils/CoordinatorExecutor.java | 46 -------------
.../apache/hudi/sink/utils/NonThrownExecutor.java | 80 +++++++++++++++++++---
.../java/org/apache/hudi/util/CompactionUtil.java | 39 ++++++++---
.../hudi/sink/utils/MockCoordinatorExecutor.java | 21 ++++--
.../org/apache/hudi/utils/TestCompactionUtil.java | 6 +-
11 files changed, 162 insertions(+), 89 deletions(-)
delete mode 100644
hudi-flink/src/main/java/org/apache/hudi/sink/utils/CoordinatorExecutor.java
