diff --git a/core/src/main/java/org/apache/iceberg/BaseDistributedDataScan.java b/core/src/main/java/org/apache/iceberg/BaseDistributedDataScan.java index 263830a53b3c..0839b4f10aa8 100644 --- a/core/src/main/java/org/apache/iceberg/BaseDistributedDataScan.java +++ b/core/src/main/java/org/apache/iceberg/BaseDistributedDataScan.java @@ -392,7 +392,7 @@ private ResidualEvaluator newResidualEvaluator(PartitionSpec spec) { private Map specCache(Function load) { Map cache = Maps.newHashMap(); - table().specs().forEach((specId, spec) -> cache.put(specId, load.apply(spec))); + specsById().forEach((specId, spec) -> cache.put(specId, load.apply(spec))); return cache; }