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());