From bd90a3831cfeec8dc1d3d9fffff40d27c5c9c5fc Mon Sep 17 00:00:00 2001
From: congqixia <congqi.xia@zilliz.com>
Date: Mon, 25 Oct 2021 18:01:50 +0800
Subject: [PATCH] Allow flushed segments trigger flushe process (#10539)

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

diff --git a/internal/datanode/data_node.go b/internal/datanode/data_node.go
index 2405cfdb15..b6cf92f8b4 100644
--- a/internal/datanode/data_node.go
+++ b/internal/datanode/data_node.go
@@ -494,7 +494,7 @@ func (node *DataNode) getChannelNamebySegmentID(segID UniqueID) string {
 	node.chanMut.RLock()
 	defer node.chanMut.RUnlock()
 	for name, dataSync := range node.vchan2SyncService {
-		if dataSync.replica.hasSegment(segID, false) {
+		if dataSync.replica.hasSegment(segID, true) {
 			return name
 		}
 	}