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():