fix: Use correct release func when datanode unwatch a channel

See also milvus-io#35654 Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
congqixia · Aug 23, 2024 · 9420b2d · 9420b2d
1 parent 946881e
commit 9420b2d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/internal/datanode/channel_manager.go b/internal/datanode/channel_manager.go
@@ -70,7 +70,7 @@ func NewChannelManager(dn *DataNode) *ChannelManagerImpl {
 		opRunners:     typeutil.NewConcurrentMap[string, *opRunner](),
 		abnormals:     typeutil.NewConcurrentMap[int64, string](),
 
-		releaseFunc: dn.flowgraphManager.RemoveFlowgraph,
+		releaseFunc: dn.tryToReleaseFlowgraph,
 
 		closeCh: lifetime.NewSafeChan(),
 	}