This is an automated email from the ASF dual-hosted git repository.
garyli pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git.
from fe5d2e7 [HUDI-2206] Fix checkpoint blocked because
getLastPendingInstant() action after than restoreWriteMetadata() action (#3326)
add c89bf1d [HUDI-2205] Rollback inflight compaction for flink writer
(#3320)
No new revisions were added by this update.
Summary of changes:
.../hudi/sink/compact/CompactionPlanOperator.java | 2 +-
.../sink/compact/CompactionPlanSourceFunction.java | 4 -
.../hudi/sink/compact/HoodieFlinkCompactor.java | 22 ++++--
.../java/org/apache/hudi/util/CompactionUtil.java | 5 +-
.../org/apache/hudi/utils/TestCompactionUtil.java | 87 ++++++++++++++++++++++
5 files changed, 105 insertions(+), 15 deletions(-)
create mode 100644
hudi-flink/src/test/java/org/apache/hudi/utils/TestCompactionUtil.java
