Skip to content

Commit 8807ee7

Browse files
author
Jan Kaul
committed
fix updatig files-to-overwrite
1 parent c5664b6 commit 8807ee7

1 file changed

Lines changed: 5 additions & 2 deletions

File tree

  • iceberg-rust/src/table/transaction

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

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -186,10 +186,13 @@ impl<'table> TableTransaction<'table> {
186186

187187
if let Some(ref mut operation) = self.operations[OVERWRITE_INDEX] {
188188
if let Operation::Overwrite {
189-
data_files: old, ..
189+
data_files: old_data_files,
190+
files_to_overwrite: old_files_to_overwrite,
191+
..
190192
} = operation
191193
{
192-
old.extend_from_slice(&files);
194+
old_data_files.extend_from_slice(&files);
195+
old_files_to_overwrite.extend(files_to_overwrite);
193196
}
194197
} else {
195198
self.operations[OVERWRITE_INDEX] = Some(Operation::Overwrite {

0 commit comments

Comments
 (0)