Skip to content

Commit 6761a61

Browse files
Jan KaulJanKaul
authored andcommitted
fix selected_manifest
1 parent 5b8593f commit 6761a61

File tree

2 files changed

+8
-8
lines changed

2 files changed

+8
-8
lines changed

iceberg-rust/src/table/manifest_list.rs

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -902,8 +902,12 @@ impl<'schema, 'metadata> ManifestListWriter<'schema, 'metadata> {
902902
&self.table_metadata.format_version,
903903
)?;
904904

905-
let bounds = self
906-
.selected_data_manifest
905+
let selected_manifest = match content {
906+
Content::Data => self.selected_data_manifest.take(),
907+
Content::Deletes => self.selected_delete_manifest.take(),
908+
};
909+
910+
let bounds = selected_manifest
907911
.as_ref()
908912
.and_then(|x| x.partitions.as_deref())
909913
.map(summary_to_rectangle)
@@ -914,10 +918,6 @@ impl<'schema, 'metadata> ManifestListWriter<'schema, 'metadata> {
914918
})
915919
.unwrap_or(self.bounding_partition_values.clone());
916920

917-
let selected_manifest = match content {
918-
Content::Data => self.selected_data_manifest.take(),
919-
Content::Deletes => self.selected_delete_manifest.take(),
920-
};
921921
let selected_manifest_bytes_opt = prefetch_manifest(&selected_manifest, &object_store);
922922

923923
// Split datafiles
@@ -1131,7 +1131,7 @@ impl<'schema, 'metadata> ManifestListWriter<'schema, 'metadata> {
11311131
Ok(())
11321132
}
11331133

1134-
pub(crate) fn selected_manifest(&self) -> Option<&ManifestListEntry> {
1134+
pub(crate) fn selected_data_manifest(&self) -> Option<&ManifestListEntry> {
11351135
self.selected_data_manifest.as_ref()
11361136
}
11371137

iceberg-rust/src/table/transaction/operation.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -484,7 +484,7 @@ impl Operation {
484484
let snapshot_id = generate_snapshot_id();
485485

486486
let selected_manifest_location = manifest_list_writer
487-
.selected_manifest()
487+
.selected_data_manifest()
488488
.map(|x| x.manifest_path.clone())
489489
.ok_or(Error::NotFound("Selected manifest".to_owned()))?;
490490

0 commit comments

Comments
 (0)