diff --git a/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/FilesTable.java b/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/FilesTable.java index 27118a6269ce..0fe50b996dbf 100644 --- a/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/FilesTable.java +++ b/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/FilesTable.java @@ -50,6 +50,8 @@ import static io.trino.spi.type.VarbinaryType.VARBINARY; import static io.trino.spi.type.VarcharType.VARCHAR; import static java.util.Objects.requireNonNull; +import static org.apache.iceberg.MetadataTableType.FILES; +import static org.apache.iceberg.MetadataTableUtils.createMetadataTableInstance; public class FilesTable implements SystemTable @@ -108,7 +110,8 @@ private static List buildPages(ConnectorTableMetadata tableMetadata, Table PageListBuilder pagesBuilder = PageListBuilder.forTable(tableMetadata); Map idToTypeMapping = getIcebergIdToTypeMapping(icebergTable.schema()); - TableScan tableScan = icebergTable.newScan() + TableScan tableScan = createMetadataTableInstance(icebergTable, FILES) + .newScan() .useSnapshot(snapshotId) .includeColumnStats();