This is an automated email from the ASF dual-hosted git repository.

amoghj pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg.git


The following commit(s) were added to refs/heads/main by this push:
     new af5be32fbe Core: Fix generated position delete file spec (#11458)
af5be32fbe is described below

commit af5be32fbef36690d32b5e53c4153b709d8db188
Author: Anton Okolnychyi <[email protected]>
AuthorDate: Mon Nov 4 15:40:21 2024 +0100

    Core: Fix generated position delete file spec (#11458)
---
 core/src/test/java/org/apache/iceberg/FileGenerationUtil.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/core/src/test/java/org/apache/iceberg/FileGenerationUtil.java 
b/core/src/test/java/org/apache/iceberg/FileGenerationUtil.java
index f66496ae66..715a9d6db2 100644
--- a/core/src/test/java/org/apache/iceberg/FileGenerationUtil.java
+++ b/core/src/test/java/org/apache/iceberg/FileGenerationUtil.java
@@ -102,13 +102,13 @@ public class FileGenerationUtil {
   }
 
   public static DeleteFile generatePositionDeleteFile(Table table, DataFile 
dataFile) {
-    PartitionSpec spec = table.spec();
+    PartitionSpec spec = table.specs().get(dataFile.specId());
     StructLike partition = dataFile.partition();
     LocationProvider locations = table.locationProvider();
     String path = locations.newDataLocation(spec, partition, 
generateFileName());
     long fileSize = generateFileSize();
     Metrics metrics = generatePositionDeleteMetrics(dataFile);
-    return FileMetadata.deleteFileBuilder(table.spec())
+    return FileMetadata.deleteFileBuilder(spec)
         .ofPositionDeletes()
         .withPath(path)
         .withPartition(partition)

Reply via email to