diff --git a/plugin/trino-delta-lake/src/main/java/io/trino/plugin/deltalake/DeltaLakeMetadata.java b/plugin/trino-delta-lake/src/main/java/io/trino/plugin/deltalake/DeltaLakeMetadata.java
index fd88b2465947..099227b2e12a 100644
--- a/plugin/trino-delta-lake/src/main/java/io/trino/plugin/deltalake/DeltaLakeMetadata.java
+++ b/plugin/trino-delta-lake/src/main/java/io/trino/plugin/deltalake/DeltaLakeMetadata.java
@@ -1640,7 +1640,7 @@ public void finishMerge(ConnectorSession session, ConnectorMergeTableHandle merg
         List<DataFileInfo> cdcFiles = ImmutableList.copyOf(split.get(false));
 
         if (mergeHandle.getInsertTableHandle().isRetriesEnabled()) {
-            cleanExtraOutputFilesForUpdate(session, Location.of(handle.getLocation()), allFiles);
+            cleanExtraOutputFiles(session, Location.of(handle.getLocation()), allFiles);
         }
 
         Optional<Long> checkpointInterval = handle.getMetadataEntry().getCheckpointInterval();
@@ -2816,15 +2816,6 @@ private void cleanExtraOutputFiles(ConnectorSession session, Location baseLocati
         cleanExtraOutputFiles(session, writtenFilePaths);
     }
 
-    private void cleanExtraOutputFilesForUpdate(ConnectorSession session, Location baseLocation, List<DataFileInfo> newFiles)
-    {
-        Set<Location> writtenFilePaths = newFiles.stream()
-                .map(dataFileInfo -> baseLocation.appendPath(dataFileInfo.getPath()))
-                .collect(toImmutableSet());
-
-        cleanExtraOutputFiles(session, writtenFilePaths);
-    }
-
     private void cleanExtraOutputFiles(ConnectorSession session, Set<Location> validWrittenFilePaths)
     {
         Set<Location> fileLocations = validWrittenFilePaths.stream()