From bf71965f58c7de8793fa976797ccab839543236d Mon Sep 17 00:00:00 2001
From: godchen <qingxiang.chen@zilliz.com>
Date: Fri, 15 Oct 2021 17:02:37 +0800
Subject: [PATCH] Check watchlist error (#9953)

Signed-off-by: godchen <qingxiang.chen@zilliz.com>
---
 internal/datanode/data_node.go | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/internal/datanode/data_node.go b/internal/datanode/data_node.go
index 48deedc5a8..bd682502db 100644
--- a/internal/datanode/data_node.go
+++ b/internal/datanode/data_node.go
@@ -209,7 +209,11 @@ func (node *DataNode) StartWatchChannels(ctx context.Context) {
 	watchPrefix := fmt.Sprintf("%s/%d", Params.ChannelWatchSubPath, node.NodeID)
 	evtChan := node.kvClient.WatchWithPrefix(watchPrefix)
 	// after watch, first check all exists nodes first
-	node.checkWatchedList()
+	err := node.checkWatchedList()
+	if err != nil {
+		log.Warn("StartWatchChannels failed", zap.Error(err))
+		return
+	}
 	for {
 		select {
 		case <-ctx.Done():