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)