diff --git a/internal/distributed/datacoord/client/client.go b/internal/distributed/datacoord/client/client.go
index 8167cd974a..cc52ae3010 100644
--- a/internal/distributed/datacoord/client/client.go
+++ b/internal/distributed/datacoord/client/client.go
@@ -13,6 +13,7 @@ package grpcdatacoordclient
 
 import (
 	"context"
+	"errors"
 	"fmt"
 	"time"
 
@@ -124,7 +125,7 @@ func (c *Client) recall(caller func() (interface{}, error)) (interface{}, error)
 	}
 	err = c.connect()
 	if err != nil {
-		return ret, err
+		return ret, errors.New("Connect to datacoord failed with error:\n" + err.Error())
 	}
 	ret, err = caller()
 	if err == nil {
diff --git a/internal/distributed/datanode/client/client.go b/internal/distributed/datanode/client/client.go
index 73b90d5e78..1f29c758c4 100644
--- a/internal/distributed/datanode/client/client.go
+++ b/internal/distributed/datanode/client/client.go
@@ -13,6 +13,7 @@ package grpcdatanodeclient
 
 import (
 	"context"
+	"errors"
 	"fmt"
 	"time"
 
@@ -104,7 +105,7 @@ func (c *Client) recall(caller func() (interface{}, error)) (interface{}, error)
 	}
 	err = c.connect()
 	if err != nil {
-		return ret, err
+		return ret, errors.New("Connect to datanode failed with error:\n" + err.Error())
 	}
 	ret, err = caller()
 	if err == nil {
diff --git a/internal/distributed/indexcoord/client/client.go b/internal/distributed/indexcoord/client/client.go
index 6c8a03f8ed..fad3f9c565 100644
--- a/internal/distributed/indexcoord/client/client.go
+++ b/internal/distributed/indexcoord/client/client.go
@@ -13,6 +13,7 @@ package grpcindexcoordclient
 
 import (
 	"context"
+	"errors"
 	"fmt"
 	"time"
 
@@ -127,7 +128,7 @@ func (c *Client) recall(caller func() (interface{}, error)) (interface{}, error)
 	}
 	err = c.connect()
 	if err != nil {
-		return ret, err
+		return ret, errors.New("Connect to indexcoord failed with error:\n" + err.Error())
 	}
 	ret, err = caller()
 	if err == nil {
diff --git a/internal/distributed/indexnode/client/client.go b/internal/distributed/indexnode/client/client.go
index 67fa96ee28..6ce843b983 100644
--- a/internal/distributed/indexnode/client/client.go
+++ b/internal/distributed/indexnode/client/client.go
@@ -13,6 +13,7 @@ package grpcindexnodeclient
 
 import (
 	"context"
+	"errors"
 	"fmt"
 	"time"
 
@@ -99,7 +100,7 @@ func (c *Client) recall(caller func() (interface{}, error)) (interface{}, error)
 	}
 	err = c.connect()
 	if err != nil {
-		return ret, err
+		return ret, errors.New("Connect to indexnode failed with error:\n" + err.Error())
 	}
 	ret, err = caller()
 	if err == nil {
diff --git a/internal/distributed/proxy/client/client.go b/internal/distributed/proxy/client/client.go
index db2a0cc17e..a48ea14d61 100644
--- a/internal/distributed/proxy/client/client.go
+++ b/internal/distributed/proxy/client/client.go
@@ -13,6 +13,7 @@ package grpcproxyclient
 
 import (
 	"context"
+	"errors"
 	"fmt"
 	"time"
 
@@ -98,7 +99,7 @@ func (c *Client) recall(caller func() (interface{}, error)) (interface{}, error)
 	}
 	err = c.connect()
 	if err != nil {
-		return ret, err
+		return ret, errors.New("Connect to proxy failed with error:\n" + err.Error())
 	}
 	ret, err = caller()
 	if err == nil {
diff --git a/internal/distributed/querycoord/client/client.go b/internal/distributed/querycoord/client/client.go
index 18640d0163..c9ab3a2b2f 100644
--- a/internal/distributed/querycoord/client/client.go
+++ b/internal/distributed/querycoord/client/client.go
@@ -13,6 +13,7 @@ package grpcquerycoordclient
 
 import (
 	"context"
+	"errors"
 	"fmt"
 	"time"
 
@@ -126,7 +127,7 @@ func (c *Client) recall(caller func() (interface{}, error)) (interface{}, error)
 	}
 	err = c.connect()
 	if err != nil {
-		return ret, err
+		return ret, errors.New("Connect to querycoord failed with error:\n" + err.Error())
 	}
 	ret, err = caller()
 	if err == nil {
diff --git a/internal/distributed/querynode/client/client.go b/internal/distributed/querynode/client/client.go
index c2803bd3eb..a9cb8189ee 100644
--- a/internal/distributed/querynode/client/client.go
+++ b/internal/distributed/querynode/client/client.go
@@ -13,6 +13,7 @@ package grpcquerynodeclient
 
 import (
 	"context"
+	"errors"
 	"fmt"
 	"time"
 
@@ -99,7 +100,7 @@ func (c *Client) recall(caller func() (interface{}, error)) (interface{}, error)
 	}
 	err = c.connect()
 	if err != nil {
-		return ret, err
+		return ret, errors.New("Connect to querynode failed with error:\n" + err.Error())
 	}
 	ret, err = caller()
 	if err == nil {
diff --git a/internal/distributed/rootcoord/client/client.go b/internal/distributed/rootcoord/client/client.go
index 8fcebc57f6..2ab8518847 100644
--- a/internal/distributed/rootcoord/client/client.go
+++ b/internal/distributed/rootcoord/client/client.go
@@ -13,6 +13,7 @@ package grpcrootcoordclient
 
 import (
 	"context"
+	"errors"
 	"fmt"
 	"time"
 
@@ -147,7 +148,7 @@ func (c *GrpcClient) recall(caller func() (interface{}, error)) (interface{}, er
 	}
 	err = c.connect()
 	if err != nil {
-		return ret, err
+		return ret, errors.New("Connect to rootcoord failed with error:\n" + err.Error())
 	}
 	ret, err = caller()
 	if err == nil {