lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-1485] Fix Deletes issued without any prior commits exception (#2361)

Browse Source
This commit is contained in:
wangxianghu
2020-12-22 23:10:19 +08:00
committed by GitHub
parent f8ccb2872d
commit 01ad449ad6
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/AbstractHoodieWriteClient.java
View File

@@ -845,7 +845,8 @@ public abstract class AbstractHoodieWriteClient<T extends HoodieRecordPayload, I
try { try {
HoodieActiveTimeline activeTimeline = metaClient.getActiveTimeline(); HoodieActiveTimeline activeTimeline = metaClient.getActiveTimeline();
Option<HoodieInstant> lastInstant = 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(); .lastInstant();
if (lastInstant.isPresent()) { if (lastInstant.isPresent()) {
HoodieCommitMetadata commitMetadata = HoodieCommitMetadata.fromBytes( HoodieCommitMetadata commitMetadata = HoodieCommitMetadata.fromBytes(