This is an automated email from the ASF dual-hosted git repository.

zhongxjian pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/dubbo-kubernetes.git


The following commit(s) were added to refs/heads/master by this push:
     new b78df9e9 [horus] fix typo (#384)
b78df9e9 is described below

commit b78df9e9591a42e36d566578336be5e8ed00182d
Author: mfordjody <[email protected]>
AuthorDate: Thu Sep 26 21:44:11 2024 +0800

    [horus] fix typo (#384)
---
 app/horus/core/horuser/node_restart.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/app/horus/core/horuser/node_restart.go 
b/app/horus/core/horuser/node_restart.go
index fd232d4c..507bf330 100644
--- a/app/horus/core/horuser/node_restart.go
+++ b/app/horus/core/horuser/node_restart.go
@@ -54,13 +54,13 @@ func (h *Horuser) RestartOrRepair(ctx context.Context) {
 func (h *Horuser) TryRestart(node db.NodeDataInfo) {
        err := h.Drain(node.NodeName, node.ClusterName)
        if err != nil {
-               msg += fmt.Sprintf("\n【安全驱逐节点尝试重启就绪:%v】\n", err)
+               msg := fmt.Sprintf("\n【安全驱逐节点尝试重启就绪:%v】\n", err)
                alert.DingTalkSend(h.cc.NodeDownTime.DingTalk, msg)
                return
        }
        msg := fmt.Sprintf("\n【节点正在尝试重启】\n 节点:%v\n 日期:%v\n 集群:%v\n", 
node.NodeName, node.FirstDate, node.ClusterName)
 
-       err := h.UnCordon(node.NodeName, node.ClusterName)
+       err = h.UnCordon(node.NodeName, node.ClusterName)
        if err != nil {
                msg += fmt.Sprintf("\n【取消不可调度状态失败:%v】\n", err)
                alert.DingTalkSend(h.cc.NodeDownTime.DingTalk, msg)

Reply via email to