lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-4109] Copy the old record directly when it is chosen for merging (#5603)

Browse Source
This commit is contained in:
Danny Chan
2022-05-18 10:17:00 +08:00
committed by GitHub
parent ebbe56e862
commit f1f8a1abb7
1 changed files with 3 additions and 0 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/io/HoodieMergeHandle.java
View File

@@ -265,6 +265,9 @@ public class HoodieMergeHandle<T extends HoodieRecordPayload, I, K, O> extends H
if (oldRecord != record) { if (oldRecord != record) {
// the incoming record is chosen // the incoming record is chosen
isDelete = HoodieOperation.isDelete(hoodieRecord.getOperation()); isDelete = HoodieOperation.isDelete(hoodieRecord.getOperation());
} else {
// the incoming record is dropped
return false;
} }
} }
return writeRecord(hoodieRecord, indexedRecord, isDelete); return writeRecord(hoodieRecord, indexedRecord, isDelete);