diff --git a/plugin/trino-hive/src/main/java/io/trino/plugin/hive/HiveMetadata.java b/plugin/trino-hive/src/main/java/io/trino/plugin/hive/HiveMetadata.java index f210e9e53304..4bd6b6e05433 100644 --- a/plugin/trino-hive/src/main/java/io/trino/plugin/hive/HiveMetadata.java +++ b/plugin/trino-hive/src/main/java/io/trino/plugin/hive/HiveMetadata.java @@ -1479,7 +1479,6 @@ public void finishStatisticsCollection(ConnectorSession session, ConnectorTableH .collect(toImmutableMap(HiveColumnHandle::getName, column -> ImmutableSet.copyOf(metastore.getSupportedColumnStatistics(column.getType())))); Supplier emptyPartitionStatistics = Suppliers.memoize(() -> createEmptyPartitionStatistics(columnTypes, columnStatisticTypes)); - int usedComputedStatistics = 0; List partitionTypes = handle.getPartitionColumns().stream() .map(HiveColumnHandle::getType) .collect(toImmutableList()); @@ -1494,11 +1493,9 @@ public void finishStatisticsCollection(ConnectorSession session, ConnectorTableH partitionStatistics.put(partitionValues, emptyPartitionStatistics.get()); } else { - usedComputedStatistics++; partitionStatistics.put(partitionValues, createPartitionStatistics(columnTypes, collectedStatistics)); } } - verify(usedComputedStatistics == computedStatistics.size(), "All computed statistics must be used"); metastore.setPartitionStatistics(table, partitionStatistics.buildOrThrow()); } }