From a8e2a69aa2e4be21c11272b9ccf429d595126eb2 Mon Sep 17 00:00:00 2001
From: congqixia <congqi.xia@zilliz.com>
Date: Sat, 29 Oct 2022 18:47:33 +0800
Subject: [PATCH] Fix mergeSyncTask logic (#20185)

Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>

Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
---
 internal/datanode/flow_graph_insert_buffer_node.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/internal/datanode/flow_graph_insert_buffer_node.go b/internal/datanode/flow_graph_insert_buffer_node.go
index 14da8a4df2..cb9a6859d6 100644
--- a/internal/datanode/flow_graph_insert_buffer_node.go
+++ b/internal/datanode/flow_graph_insert_buffer_node.go
@@ -349,7 +349,7 @@ func (ibNode *insertBufferNode) FillInSyncTasks(fgMsg *flowGraphMsg, seg2Upload
 					zap.Bool("flushed", task.flushed),
 					zap.Bool("dropped", task.dropped),
 				)
-				return
+				continue
 			}
 
 			buf := ibNode.GetBuffer(segmentID)