diff --git a/internal/distributed/datacoord/client/client.go b/internal/distributed/datacoord/client/client.go index 8c50b2f00c..754a2da27d 100644 --- a/internal/distributed/datacoord/client/client.go +++ b/internal/distributed/datacoord/client/client.go @@ -81,7 +81,7 @@ func (c *Client) getDataCoordAddr() (string, error) { ms, ok := msess[key] if !ok { log.Debug("DataCoordClient, not existed in msess ", zap.Any("key", key), zap.Any("len of msess", len(msess))) - return "", fmt.Errorf("number of datacoord is incorrect, %d", len(msess)) + return "", fmt.Errorf("find no available datacoord, check datacoord state") } return ms.Address, nil } diff --git a/internal/distributed/indexcoord/client/client.go b/internal/distributed/indexcoord/client/client.go index 467e466846..a754a2a1a9 100644 --- a/internal/distributed/indexcoord/client/client.go +++ b/internal/distributed/indexcoord/client/client.go @@ -98,7 +98,7 @@ func (c *Client) getIndexCoordAddr() (string, error) { ms, ok := msess[key] if !ok { log.Debug("IndexCoordClient msess key not existed", zap.Any("key", key), zap.Any("len of msess", len(msess))) - return "", fmt.Errorf("number of indexcoord is incorrect, %d", len(msess)) + return "", fmt.Errorf("find no available indexcoord, check indexcoord state") } return ms.Address, nil } diff --git a/internal/distributed/querycoord/client/client.go b/internal/distributed/querycoord/client/client.go index 4c97175ec6..9965001a2b 100644 --- a/internal/distributed/querycoord/client/client.go +++ b/internal/distributed/querycoord/client/client.go @@ -81,7 +81,7 @@ func (c *Client) getQueryCoordAddr() (string, error) { ms, ok := msess[key] if !ok { log.Debug("QueryCoordClient msess key not existed", zap.Any("key", key)) - return "", fmt.Errorf("number of querycoord is incorrect, %d", len(msess)) + return "", fmt.Errorf("find no available querycoord, check querycoord state") } return ms.Address, nil } diff --git a/internal/distributed/rootcoord/client/client.go b/internal/distributed/rootcoord/client/client.go index 161048b519..0b9816b2ee 100644 --- a/internal/distributed/rootcoord/client/client.go +++ b/internal/distributed/rootcoord/client/client.go @@ -91,7 +91,7 @@ func (c *Client) getRootCoordAddr() (string, error) { ms, ok := msess[key] if !ok { log.Warn("RootCoordClient mess key not exist", zap.Any("key", key)) - return "", fmt.Errorf("number of RootCoord is incorrect, %d", len(msess)) + return "", fmt.Errorf("find no available rootcoord, check rootcoord state") } log.Debug("RootCoordClient GetSessions success", zap.String("address", ms.Address)) return ms.Address, nil