Fix panic if the query key not exist (#795)

pingcap · Sep 21, 2020 · 81ec3eb · 81ec3eb
1 parent 8ca0da1
commit 81ec3eb
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/pkg/cluster/api/binlog.go b/pkg/cluster/api/binlog.go
@@ -141,6 +141,10 @@ func (c *BinlogClient) updateStatus(ty string, nodeID string, state string) erro
 		return errors.AddStack(err)
 	}
 
+	if len(resp.Kvs) == 0 {
+		return errors.Errorf("no pump with node id: %v", nodeID)
+	}
+
 	var nodeStatus NodeStatus
 	err = json.Unmarshal(resp.Kvs[0].Value, &nodeStatus)
 	if err != nil {