From ec830e1240e84e033fa84958f4d0b85e91d3b2a6 Mon Sep 17 00:00:00 2001
From: aoiasd <45024769+aoiasd@users.noreply.github.com>
Date: Wed, 11 Oct 2023 18:49:33 +0800
Subject: [PATCH] fix use same logidx in different field (#27492)

Signed-off-by: aoiasd <zhicheng.yue@zilliz.com>
---
 internal/datanode/flush_manager.go | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/internal/datanode/flush_manager.go b/internal/datanode/flush_manager.go
index 0d326c71f4..120e63fea2 100644
--- a/internal/datanode/flush_manager.go
+++ b/internal/datanode/flush_manager.go
@@ -467,7 +467,6 @@ func (m *rendezvousFlushManager) flushBufferData(data *BufferData, segmentID Uni
 
 	// binlogs
 	for _, blob := range binLogBlobs {
-		defer func() { logidx++ }()
 		fieldID, err := strconv.ParseInt(blob.GetKey(), 10, 64)
 		if err != nil {
 			log.Error("Flush failed ... cannot parse string to fieldID ..", zap.Error(err))
@@ -485,6 +484,8 @@ func (m *rendezvousFlushManager) flushBufferData(data *BufferData, segmentID Uni
 			LogPath:       key,
 			LogSize:       int64(fieldMemorySize[fieldID]),
 		}
+
+		logidx += 1
 	}
 
 	// pk stats binlog