Remove duplicate code

The stream traversal is done already earlier in the method, reuse.
trinodb · Aug 2, 2023 · 0aa3da0 · 0aa3da0
1 parent ca6fc78
commit 0aa3da0
Showing 1 changed file with 1 addition and 3 deletions.
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
@@ -2225,9 +2225,7 @@ private void cleanupFailedWrite(ConnectorSession session, String tableLocation,
         }
         catch (Exception e) {
             // Can be safely ignored since a VACUUM from DeltaLake will take care of such orphaned files
-            LOG.warn(e, "Failed cleanup of leftover files from failed write, files are: %s", dataFiles.stream()
-                    .map(dataFileInfo -> appendPath(tableLocation, dataFileInfo.getPath()))
-                    .collect(toImmutableList()));
+            LOG.warn(e, "Failed cleanup of leftover files from failed write, files are: %s", filesToDelete);
         }
     }