BugFix: PartitionStatsUtil#computeStats returns incomplete stats in c…

…ase of partition evolution
apache · Jan 30, 2025 · 1f893e6 · 1f893e6
1 parent 2a0d5e8
commit 1f893e6
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/core/src/main/java/org/apache/iceberg/PartitionStatsUtil.java b/core/src/main/java/org/apache/iceberg/PartitionStatsUtil.java
@@ -96,7 +96,10 @@ private static PartitionMap<PartitionStats> collectStats(
         StructLike key = keyTemplate.copyFor(coercedPartition);
         Snapshot snapshot = table.snapshot(entry.snapshotId());
         PartitionStats stats =
-            statsMap.computeIfAbsent(specId, key, () -> new PartitionStats(key, specId));
+            statsMap.computeIfAbsent(
+                specId,
+                ((PartitionData) file.partition()).copy(),
+                () -> new PartitionStats(key, specId));
         if (entry.isLive()) {
           stats.liveEntry(file, snapshot);
         } else {