lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[MINOR] Repeated execution of update status (#5089)

Browse Source
This commit is contained in:
Bo Cui
2022-03-31 05:30:06 +08:00
committed by GitHub
parent 2b60641d17
commit 17d11f4839
1 changed files with 0 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/BucketAssignFunction.java
View File

@@ -188,7 +188,6 @@ public class BucketAssignFunction<K, I, O extends HoodieRecord<?>>
out.collect((O) deleteRecord); out.collect((O) deleteRecord);
} }
location = getNewRecordLocation(partitionPath); location = getNewRecordLocation(partitionPath);
updateIndexState(partitionPath, location);
} else { } else {
location = oldLoc.toLocal("U"); location = oldLoc.toLocal("U");
this.bucketAssigner.addUpdate(partitionPath, location.getFileId()); this.bucketAssigner.addUpdate(partitionPath, location.getFileId());