diff --git a/pkg/volume/csi/csi_client.go b/pkg/volume/csi/csi_client.go index 4a4cb4176b..36055db9aa 100644 --- a/pkg/volume/csi/csi_client.go +++ b/pkg/volume/csi/csi_client.go @@ -95,6 +95,10 @@ func (c *csiDriverClient) NodeGetInfo(ctx context.Context) ( nodeClient := csipb.NewNodeClient(conn) res, err := nodeClient.NodeGetInfo(ctx, &csipb.NodeGetInfoRequest{}) + if err != nil { + return "", 0, nil, err + } + return res.GetNodeId(), res.GetMaxVolumesPerNode(), res.GetAccessibleTopology(), nil }