fix: binlog reader not released in time (#36078)

#36077 Signed-off-by: fengjun2016 <[email protected]>
milvus-io · Sep 7, 2024 · 62f4a6a · 62f4a6a
1 parent 9a8ed9a
commit 62f4a6a
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/internal/storage/data_codec.go b/internal/storage/data_codec.go
@@ -437,6 +437,7 @@ func (insertCodec *InsertCodec) DeserializeInto(fieldBinlogs []*Blob, rowNum int
 		for {
 			eventReader, err := binlogReader.NextEventReader()
 			if err != nil {
+				binlogReader.Close()
 				return InvalidUniqueID, InvalidUniqueID, InvalidUniqueID, err
 			}
 			if eventReader == nil {