Rollback inflight commits as well when rolling back to savepoint

apache · Jun 14, 2017 · dda28c0 · dda28c0
1 parent db6150c
commit dda28c0
Showing 1 changed file with 1 addition and 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
@@ -539,7 +539,7 @@ public boolean rollbackToSavepoint(String savepointTime) {
         HoodieTable<T> 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);