File tree Expand file tree Collapse file tree 1 file changed +4
-2
lines changed
core/src/main/java/org/apache/iceberg Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -1081,9 +1081,11 @@ private List<ManifestFile> newDeleteFilesAsManifests() {
10811081 tableName ,
10821082 ops ().current ().specsById (),
10831083 ThreadPools .getDeleteWorkerPool ());
1084-
1084+ // Prevent commiting duplicate V2 deletes by deduping them
10851085 Map <Integer , List <DeleteFile >> newDeleteFilesBySpec =
1086- Streams .stream (Iterables .concat (mergedDVs , validDVs , positionAndEqualityDeletes ))
1086+ Streams .stream (
1087+ Iterables .concat (
1088+ mergedDVs , validDVs , DeleteFileSet .of (positionAndEqualityDeletes )))
10871089 .map (file -> Delegates .pendingDeleteFile (file , file .dataSequenceNumber ()))
10881090 .collect (Collectors .groupingBy (ContentFile ::specId ));
10891091 newDeleteFilesBySpec .forEach (
You can’t perform that action at this time.
0 commit comments