diff --git a/internal/distributed/queryservice/client/client.go b/internal/distributed/queryservice/client/client.go
index b3053759b6145c5e05354ba2351a26b93a15c949..5a1f1466fbae3c3d54a10fff3fb8aa3efe7bf7d3 100644
--- a/internal/distributed/queryservice/client/client.go
+++ b/internal/distributed/queryservice/client/client.go
@@ -79,6 +79,8 @@ func (c *Client) Init() error {
 	log.Debug("QueryServiceClient try connect QueryService", zap.Any("c.addr", c.addr))
 	if c.addr != "" {
 		connectGrpcFunc := func() error {
+			ctx, cancel := context.WithTimeout(context.Background(), c.timeout)
+			defer cancel()
 			ctx, cancelFunc := context.WithTimeout(c.ctx, c.timeout)
 			defer cancelFunc()
 			log.Debug("QueryServiceClient try connect ", zap.String("address", c.addr))