From 1a8e2e5e85cd1484d05935eacfb2391cca2401a7 Mon Sep 17 00:00:00 2001 From: xige-16 Date: Wed, 24 Nov 2021 19:27:15 +0800 Subject: [PATCH] Establish a grpc connection When init queryNode client (#12236) Signed-off-by: xige-16 --- internal/distributed/querynode/client/client.go | 3 ++- internal/distributed/querynode/client/client_test.go | 3 +-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/internal/distributed/querynode/client/client.go b/internal/distributed/querynode/client/client.go index edd870b350..080ba4f934 100644 --- a/internal/distributed/querynode/client/client.go +++ b/internal/distributed/querynode/client/client.go @@ -110,7 +110,8 @@ func NewClient(ctx context.Context, addr string) (*Client, error) { // Init initializes QueryNode's grpc client. func (c *Client) Init() error { Params.Init() - return nil + _, err := c.getGrpcClient() + return err } func (c *Client) connect(retryOptions ...retry.Option) error { diff --git a/internal/distributed/querynode/client/client_test.go b/internal/distributed/querynode/client/client_test.go index 6c3c73e384..d2585b6555 100644 --- a/internal/distributed/querynode/client/client_test.go +++ b/internal/distributed/querynode/client/client_test.go @@ -97,8 +97,7 @@ func Test_NewClient(t *testing.T) { assert.Nil(t, err) assert.NotNil(t, client) - err = client.Init() - assert.Nil(t, err) + Params.Init() err = client.Start() assert.Nil(t, err)