Update BaseDistributedDataScan.java

apache · Sep 26, 2024 · fa8e52a · fa8e52a
1 parent 10140e9
commit fa8e52a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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 <R> Map<Integer, R> specCache(Function<PartitionSpec, R> load) {
     Map<Integer, R> 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;
   }