diff --git a/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/fileio/ForwardingInputFile.java b/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/fileio/ForwardingInputFile.java index 0ae98332f5da..add5c10dcf46 100644 --- a/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/fileio/ForwardingInputFile.java +++ b/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/fileio/ForwardingInputFile.java @@ -75,4 +75,10 @@ public boolean exists() throw new UncheckedIOException("Failed to check existence for file: " + location(), e); } } + + @Override + public String toString() + { + return inputFile.toString(); + } } diff --git a/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/fileio/ForwardingOutputFile.java b/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/fileio/ForwardingOutputFile.java index 9f0ae7d255d6..b03cdb059e9a 100644 --- a/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/fileio/ForwardingOutputFile.java +++ b/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/fileio/ForwardingOutputFile.java @@ -74,6 +74,12 @@ public InputFile toInputFile() return new ForwardingInputFile(fileSystem.newInputFile(outputFile.location())); } + @Override + public String toString() + { + return outputFile.toString(); + } + private static class CountingPositionOutputStream extends PositionOutputStream {