From 9672eee78adc9f7bb69b984829b82b4100636a26 Mon Sep 17 00:00:00 2001 From: "cai.zhang" Date: Sun, 5 Jan 2025 18:53:01 +0800 Subject: [PATCH] enhance: Increase the buffer capacity of notifyIndexChan to support concurrency (#38957) Signed-off-by: Cai Zhang --- internal/datacoord/server.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/datacoord/server.go b/internal/datacoord/server.go index b5c0ac15dc..ada34adad3 100644 --- a/internal/datacoord/server.go +++ b/internal/datacoord/server.go @@ -213,7 +213,7 @@ func CreateServer(ctx context.Context, factory dependency.Factory, opts ...Optio quitCh: make(chan struct{}), factory: factory, flushCh: make(chan UniqueID, 1024), - notifyIndexChan: make(chan UniqueID), + notifyIndexChan: make(chan UniqueID, 1024), dataNodeCreator: defaultDataNodeCreatorFunc, indexNodeCreator: defaultIndexNodeCreatorFunc, rootCoordClientCreator: defaultRootCoordCreatorFunc,