This is an automated email from the ASF dual-hosted git repository.

vinoyang 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 01ad449  [HUDI-1485] Fix Deletes issued without any prior commits 
exception (#2361)
01ad449 is described below

commit 01ad449ad68d9c77ee1493fcdf833df53df6106a
Author: wangxianghu <[email protected]>
AuthorDate: Tue Dec 22 23:10:19 2020 +0800

    [HUDI-1485] Fix Deletes issued without any prior commits exception (#2361)
---
 .../main/java/org/apache/hudi/client/AbstractHoodieWriteClient.java    | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/AbstractHoodieWriteClient.java
 
b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/AbstractHoodieWriteClient.java
index fd1d4b5..ef5c7ab 100644
--- 
a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/AbstractHoodieWriteClient.java
+++ 
b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/AbstractHoodieWriteClient.java
@@ -845,7 +845,8 @@ public abstract class AbstractHoodieWriteClient<T extends 
HoodieRecordPayload, I
     try {
       HoodieActiveTimeline activeTimeline = metaClient.getActiveTimeline();
       Option<HoodieInstant> lastInstant =
-          activeTimeline.filterCompletedInstants().filter(s -> 
s.getAction().equals(metaClient.getCommitActionType()))
+          activeTimeline.filterCompletedInstants().filter(s -> 
s.getAction().equals(metaClient.getCommitActionType())
+          || s.getAction().equals(HoodieActiveTimeline.REPLACE_COMMIT_ACTION))
               .lastInstant();
       if (lastInstant.isPresent()) {
         HoodieCommitMetadata commitMetadata = HoodieCommitMetadata.fromBytes(

Reply via email to