From e2626c7b9ed8d34373408af0c76588e2beeabbd4 Mon Sep 17 00:00:00 2001
From: congqixia <congqi.xia@zilliz.com>
Date: Fri, 24 May 2024 18:59:42 +0800
Subject: [PATCH] fix: [2.4]Allocate new slice for each batch in streaming
 reader (#33360)

Cherry-pick from master
pr: #33359
Related to #33268

Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
---
 internal/storage/serde.go | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/internal/storage/serde.go b/internal/storage/serde.go
index 7a64edf79b65..8b8f77ca53f9 100644
--- a/internal/storage/serde.go
+++ b/internal/storage/serde.go
@@ -587,9 +587,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
 		}