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),