Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
12 changes: 6 additions & 6 deletions pkg/cluster/api/pdapi.go
Original file line number Diff line number Diff line change
Expand Up @@ -285,8 +285,8 @@ func (pc *PDClient) WaitLeader(retryOpt *utils.RetryOption) error {
}

// return error by default, to make the retry work
pc.l().Debugf("Still waitting for the PD leader to be elected")
return perrs.New("still waitting for the PD leader to be elected")
pc.l().Debugf("Still waiting for the PD leader to be elected")
return perrs.New("still waiting for the PD leader to be elected")
}, *retryOpt); err != nil {
return fmt.Errorf("error getting PD leader, %v", err)
}
Expand Down Expand Up @@ -444,8 +444,8 @@ func (pc *PDClient) EvictPDLeader(retryOpt *utils.RetryOption) error {
}

// return error by default, to make the retry work
pc.l().Debugf("Still waitting for the PD leader to transfer")
return perrs.New("still waitting for the PD leader to transfer")
pc.l().Debugf("Still waiting for the PD leader to transfer")
return perrs.New("still waiting for the PD leader to transfer")
}, *retryOpt); err != nil {
return fmt.Errorf("error evicting PD leader, %v", err)
}
Expand Down Expand Up @@ -524,7 +524,7 @@ func (pc *PDClient) EvictStoreLeader(host string, retryOpt *utils.RetryOption, c
return nil
}
pc.l().Infof(
"\t Still waitting for %d store leaders to transfer...",
"\t Still waiting for %d store leaders to transfer...",
leaderCount,
)

Expand Down Expand Up @@ -732,7 +732,7 @@ func (pc *PDClient) DelPD(name string, retryOpt *utils.RetryOption) error {
// check if the deleted member still present
for _, member := range currMembers.Members {
if member.Name == name {
return perrs.New("still waitting for the PD node to be deleted")
return perrs.New("still waiting for the PD node to be deleted")
}
}

Expand Down