Fix querynode tt producer leak (#7059)

Signed-off-by: N Congqi Xia <congqi.xia@zilliz.com>

Fix querynode tt producer leak (#7059)
Signed-off-by: N Congqi Xia <congqi.xia@zilliz.com>
3f21e3d0 · congqixia · GitHub · b9d3897d · 3f21e3d0
隐藏空白更改
内联并排

Showing with 2 addition and 1 deletion

internal/querynode/flow_graph_service_time_node.go internal/querynode/flow_graph_service_time_node.go +2 -1

未找到文件。
--- a/internal/querynode/flow_graph_service_time_node.go
+++ b/internal/querynode/flow_graph_service_time_node.go
@@ -36,7 +36,8 @@ func (stNode *serviceTimeNode) Name() string {
 }

 func (stNode *serviceTimeNode) Close() {
-	//stNode.timeTickMsgStream.Close()
+	// `Close` needs to be invoked to close producers
+	stNode.timeTickMsgStream.Close()
 }

 func (stNode *serviceTimeNode) Operate(in []flowgraph.Msg) []flowgraph.Msg {