diff --git a/internal/proxy/impl.go b/internal/proxy/impl.go
index ea8316f323..d797474739 100644
--- a/internal/proxy/impl.go
+++ b/internal/proxy/impl.go
@@ -1344,6 +1344,7 @@ func (node *Proxy) Retrieve(ctx context.Context, request *milvuspb.RetrieveReque
 		},
 		resultBuf: make(chan []*internalpb.RetrieveResults),
 		retrieve:  request,
+		chMgr:     node.chMgr,
 		qc:        node.queryCoord,
 	}