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(