From fa8e52abce0c34e95d87133fe9fbe105d787f668 Mon Sep 17 00:00:00 2001
From: liu yang <lurnagaodahua@gmail.com>
Date: Thu, 26 Sep 2024 18:32:36 +0800
Subject: [PATCH] Update BaseDistributedDataScan.java

---
 .../main/java/org/apache/iceberg/BaseDistributedDataScan.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 <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;
   }