From dda28c0b4b6263e89ff24791f6f09dc553f4c19b Mon Sep 17 00:00:00 2001 From: Prasanna Rajaperumal Date: Tue, 13 Jun 2017 12:09:36 -0700 Subject: [PATCH] Rollback inflight commits as well when rolling back to savepoint --- .../src/main/java/com/uber/hoodie/HoodieWriteClient.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hoodie-client/src/main/java/com/uber/hoodie/HoodieWriteClient.java b/hoodie-client/src/main/java/com/uber/hoodie/HoodieWriteClient.java index 208909120..57d7f8ffa 100644 --- a/hoodie-client/src/main/java/com/uber/hoodie/HoodieWriteClient.java +++ b/hoodie-client/src/main/java/com/uber/hoodie/HoodieWriteClient.java @@ -539,7 +539,7 @@ public class HoodieWriteClient implements Seriali HoodieTable table = HoodieTable .getHoodieTable(new HoodieTableMetaClient(fs, config.getBasePath(), true), config); HoodieActiveTimeline activeTimeline = table.getActiveTimeline(); - HoodieTimeline commitTimeline = table.getCompletedCommitTimeline(); + HoodieTimeline commitTimeline = table.getCommitTimeline(); HoodieInstant savePoint = new HoodieInstant(false, HoodieTimeline.SAVEPOINT_ACTION, savepointTime);