lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[MINOR] Remove unused method in HoodieActiveTimeline (#4435)

Browse Source
This commit is contained in:
xuzifu666
2021-12-24 22:29:34 +08:00
committed by GitHub
parent 032b883bd1
commit 4721073b43
1 changed files with 0 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieActiveTimeline.java
View File

@@ -196,25 +196,6 @@ public class HoodieActiveTimeline extends HoodieDefaultTimeline {
deleteInstantFile(instant); 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) { private void deleteInstantFile(HoodieInstant instant) {
LOG.info("Deleting instant " + instant); LOG.info("Deleting instant " + instant);
Path inFlightCommitFilePath = new Path(metaClient.getMetaPath(), instant.getFileName()); Path inFlightCommitFilePath = new Path(metaClient.getMetaPath(), instant.getFileName());