Skip to content

Commit 4c4c6f9

Browse files
committed
Improve exception message in remove_orphan_files
1 parent c0f75f6 commit 4c4c6f9

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/IcebergMetadata.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2397,7 +2397,7 @@ private void scanAndDeleteInvalidFiles(Table table, ConnectorSession session, Sc
23972397
deleteFutures.forEach(MoreFutures::getFutureValue);
23982398
}
23992399
catch (IOException | UncheckedIOException e) {
2400-
throw new TrinoException(ICEBERG_FILESYSTEM_ERROR, "Failed accessing data for table: " + schemaTableName, e);
2400+
throw new TrinoException(ICEBERG_FILESYSTEM_ERROR, "Failed removing orphan files for table: " + schemaTableName, e);
24012401
}
24022402
finally {
24032403
deleteFutures.forEach(future -> future.cancel(true));
@@ -2411,7 +2411,7 @@ private void deleteFiles(List<Location> files, SchemaTableName schemaTableName,
24112411
fileSystem.deleteFiles(files);
24122412
}
24132413
catch (IOException | UncheckedIOException e) {
2414-
throw new TrinoException(ICEBERG_FILESYSTEM_ERROR, "Failed accessing data for table: " + schemaTableName, e);
2414+
throw new TrinoException(ICEBERG_FILESYSTEM_ERROR, "Failed removing orphan files for table: " + schemaTableName, e);
24152415
}
24162416
}
24172417

0 commit comments

Comments
 (0)