Skip to content

Commit 212047f

Browse files
committed
Delete the oldest tracked version metadata files after commit
1 parent de260a5 commit 212047f

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/catalog/AbstractIcebergTableOperations.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -341,11 +341,11 @@ private void deleteRemovedMetadataFiles(TableMetadata base, TableMetadata metada
341341
file -> {
342342
try {
343343
io().deleteFile(file.file());
344-
} catch (RuntimeException e) {
344+
}
345+
catch (RuntimeException e) {
345346
log.warn(e, "Delete failed for previous metadata file: %s", file);
346347
}
347-
}
348-
);
348+
});
349349
}
350350
}
351351
}

0 commit comments

Comments
 (0)