Skip to content

Commit db47085

Browse files
committed
fix: logic bug
1 parent ef827f1 commit db47085

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

crates/iceberg/src/arrow/delete_file_manager.rs

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,11 +17,12 @@
1717

1818
use std::collections::HashMap;
1919
use std::future::Future;
20-
use std::ops::BitAndAssign;
20+
use std::ops::BitOrAssign;
2121
use std::pin::Pin;
2222
use std::sync::{Arc, OnceLock, RwLock};
2323
use std::task::{Context, Poll};
2424

25+
use arrow_array::{Int64Array, StringArray};
2526
use futures::channel::oneshot;
2627
use futures::future::join_all;
2728
use futures::{StreamExt, TryStreamExt};
@@ -296,7 +297,7 @@ impl DeleteFileManager {
296297
if let ParsedDeleteFileContext::DelVecs(del_vecs) = item {
297298
del_vecs.into_iter().for_each(|(key, val)| {
298299
let entry = merged_delete_vectors.entry(key).or_default();
299-
entry.bitand_assign(val);
300+
entry.bitor_assign(val);
300301
});
301302
}
302303

0 commit comments

Comments
 (0)