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 index fc337cdbeb1c..a0b96a2de5c1 100644 --- 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 @@ -760,7 +760,7 @@ public Iterator streamTableColumns(ConnectorSession sessio return Stream.of(); } String tableLocation = metastoreTable.get().location(); - TableSnapshot snapshot = getSnapshot(session, table, tableLocation, Optional.empty()); + TableSnapshot snapshot = transactionLogAccess.loadSnapshot(session, table, tableLocation); MetadataEntry metadata = transactionLogAccess.getMetadataEntry(snapshot, session); ProtocolEntry protocol = transactionLogAccess.getProtocolEntry(session, snapshot); Map columnComments = getColumnComments(metadata); @@ -771,7 +771,7 @@ public Iterator streamTableColumns(ConnectorSession sessio .collect(toImmutableList()); return Stream.of(TableColumnsMetadata.forTable(table, columnMetadata)); } - catch (NotADeltaLakeTableException e) { + catch (NotADeltaLakeTableException | IOException e) { return Stream.empty(); } catch (RuntimeException e) {