We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b1619c5 commit 9e9fe26Copy full SHA for 9e9fe26
crates/iceberg/src/transaction/utils.rs
@@ -20,6 +20,7 @@ use std::sync::Arc;
20
21
use futures::stream::{self, StreamExt};
22
use futures::TryStreamExt;
23
+use itertools::Itertools;
24
25
use crate::error::Result;
26
use crate::io::FileIO;
@@ -99,8 +100,12 @@ impl ReachableFileCleanupStrategy {
99
100
}
101
102
- stream::iter(manifest_lists_to_delete)
103
+ let manifest_lists_to_delete = manifest_lists_to_delete
104
+ .iter()
105
.map(|path| self.file_io.delete(path))
106
+ .collect_vec();
107
+
108
+ stream::iter(manifest_lists_to_delete)
109
.buffer_unordered(DEFAULT_DELETE_CONCURRENCY_LIMIT)
110
.try_collect::<Vec<_>>()
111
.await?;
0 commit comments