From 4721073b4397d76bbd813a988cb79cc9a9558358 Mon Sep 17 00:00:00 2001 From: xuzifu666 Date: Fri, 24 Dec 2021 22:29:34 +0800 Subject: [PATCH] [MINOR] Remove unused method in HoodieActiveTimeline (#4435) --- .../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 5d079f351..ee442b196 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());