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)