This is an automated email from the ASF dual-hosted git repository.

leesf pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git


The following commit(s) were added to refs/heads/master by this push:
     new 4721073  [MINOR] Remove unused method in HoodieActiveTimeline (#4435)
4721073 is described below

commit 4721073b4397d76bbd813a988cb79cc9a9558358
Author: xuzifu666 <[email protected]>
AuthorDate: Fri Dec 24 22:29:34 2021 +0800

    [MINOR] Remove unused method in HoodieActiveTimeline (#4435)
---
 .../common/table/timeline/HoodieActiveTimeline.java   | 19 -------------------
 1 file changed, 19 deletions(-)

diff --git 
a/hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieActiveTimeline.java
 
b/hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieActiveTimeline.java
index 5d079f3..ee442b1 100644
--- 
a/hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieActiveTimeline.java
+++ 
b/hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieActiveTimeline.java
@@ -196,25 +196,6 @@ public class HoodieActiveTimeline extends 
HoodieDefaultTimeline {
     deleteInstantFile(instant);
   }
 
-  private void deleteInstantFileIfExists(HoodieInstant instant) {
-    LOG.info("Deleting instant " + instant);
-    Path inFlightCommitFilePath = new Path(metaClient.getMetaPath(), 
instant.getFileName());
-    try {
-      if (metaClient.getFs().exists(inFlightCommitFilePath)) {
-        boolean result = metaClient.getFs().delete(inFlightCommitFilePath, 
false);
-        if (result) {
-          LOG.info("Removed instant " + instant);
-        } else {
-          throw new HoodieIOException("Could not delete instant " + instant);
-        }
-      } else {
-        LOG.warn("The commit " + inFlightCommitFilePath + " to remove does not 
exist");
-      }
-    } catch (IOException e) {
-      throw new HoodieIOException("Could not remove inflight commit " + 
inFlightCommitFilePath, e);
-    }
-  }
-
   private void deleteInstantFile(HoodieInstant instant) {
     LOG.info("Deleting instant " + instant);
     Path inFlightCommitFilePath = new Path(metaClient.getMetaPath(), 
instant.getFileName());

Reply via email to