diff --git a/internal/storage/serde.go b/internal/storage/serde.go index ba5256c6d13f..c75bf5aabc0b 100644 --- a/internal/storage/serde.go +++ b/internal/storage/serde.go @@ -588,9 +588,8 @@ func (deser *DeserializeReader[T]) Next() error { deser.pos = 0 deser.rec = deser.rr.Record() - if deser.values == nil { - deser.values = make([]T, deser.rec.Len()) - } + // allocate new slice preventing overwrite previous batch + deser.values = make([]T, deser.rec.Len()) if err := deser.deserializer(deser.rec, deser.values); err != nil { return err }