diff --git a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/AbstractHoodieWriteClient.java b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/AbstractHoodieWriteClient.java index ef5c7ab8a8cce..014998749ca3f 100644 --- a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/AbstractHoodieWriteClient.java +++ b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/AbstractHoodieWriteClient.java @@ -599,11 +599,6 @@ public HoodieCleanMetadata clean() { * Provides a new commit time for a write operation (insert/update/delete). */ public String startCommit() { - // NOTE : Need to ensure that rollback is done before a new commit is started - if (rollbackPending) { - // Only rollback pending commit/delta-commits. Do not touch compaction commits - rollbackPendingCommits(); - } String instantTime = HoodieActiveTimeline.createNewInstantTime(); startCommitWithTime(instantTime); return instantTime;