From 0ecf2045ed749506bfc4768545253e32a9740cd1 Mon Sep 17 00:00:00 2001 From: Jiquan Long Date: Tue, 27 Sep 2022 20:56:54 +0800 Subject: [PATCH] Fix dml stream leakage in Proxy (#19486) Signed-off-by: longjiquan Signed-off-by: longjiquan --- internal/proxy/impl.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/internal/proxy/impl.go b/internal/proxy/impl.go index 8c1acb030c..850e217812 100644 --- a/internal/proxy/impl.go +++ b/internal/proxy/impl.go @@ -115,6 +115,10 @@ func (node *Proxy) InvalidateCollectionMetaCache(ctx context.Context, request *p globalMetaCache.RemoveCollectionsByID(ctx, collectionID) } } + + // err is ignored, since this Proxy may not create dml stream for the collection. + _ = node.chMgr.removeDMLStream(collectionID) + logutil.Logger(ctx).Info("complete to invalidate collection meta cache", zap.String("role", typeutil.ProxyRole), zap.String("db", request.DbName),