Skip to content

Commit 2990897

Browse files
address comments
1 parent c93c147 commit 2990897

1 file changed

Lines changed: 3 additions & 0 deletions

File tree

crates/fluss/src/row/binary/iceberg_binary_row_writer.rs

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -134,6 +134,9 @@ impl IcebergBinaryRowWriter {
134134

135135
impl BinaryWriter for IcebergBinaryRowWriter {
136136
fn reset(&mut self) {
137+
if self.position > 0 {
138+
self.buffer[..self.position].fill(0);
139+
}
137140
self.position = 0;
138141
}
139142

0 commit comments

Comments
 (0)