From a26d6cdf23c99e7e2841e587541188b44e9fdf00 Mon Sep 17 00:00:00 2001
From: congqixia <congqi.xia@zilliz.com>
Date: Wed, 29 May 2024 14:07:44 +0800
Subject: [PATCH] fix: Remove group checker when closing qn pipeline (#33443)

See also #33442

This fix shall prevent group checker keep printing "some node(s) haven't
received input" err message after collection released

Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
---
 internal/util/pipeline/pipeline.go | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/internal/util/pipeline/pipeline.go b/internal/util/pipeline/pipeline.go
index cfc0db3e59..6e85f2d998 100644
--- a/internal/util/pipeline/pipeline.go
+++ b/internal/util/pipeline/pipeline.go
@@ -69,6 +69,11 @@ func (p *pipeline) Start() error {
 }
 
 func (p *pipeline) Close() {
+	for _, node := range p.nodes {
+		if node.Checker != nil {
+			node.Checker.Close()
+		}
+	}
 }
 
 func (p *pipeline) process() {