diff --git a/plugin/trino-delta-lake/src/main/java/io/trino/plugin/deltalake/statistics/FileBasedTableStatisticsProvider.java b/plugin/trino-delta-lake/src/main/java/io/trino/plugin/deltalake/statistics/FileBasedTableStatisticsProvider.java index 254e21b229ac..937c2907c007 100644 --- a/plugin/trino-delta-lake/src/main/java/io/trino/plugin/deltalake/statistics/FileBasedTableStatisticsProvider.java +++ b/plugin/trino-delta-lake/src/main/java/io/trino/plugin/deltalake/statistics/FileBasedTableStatisticsProvider.java @@ -103,6 +103,8 @@ public TableStatistics getTableStatistics(ConnectorSession session, DeltaLakeTab } Set predicatedColumnNames = tableHandle.getNonPartitionConstraint().getDomains().orElseThrow().keySet().stream() + // TODO Statistics for column inside complex type is not collected (https://github.com/trinodb/trino/issues/17164) + .filter(DeltaLakeColumnHandle::isBaseColumn) .map(DeltaLakeColumnHandle::getBaseColumnName) .collect(toImmutableSet()); List predicatedColumns = columnMetadata.stream()