-
Notifications
You must be signed in to change notification settings - Fork 32
Increase meta client connection timeout。 #161
base: master
Are you sure you want to change the base?
Conversation
| } | ||
|
|
||
| private val metaClient = new MetaClient(address.asJava) | ||
| private val metaClient = new MetaClient(address.asJava,6000,3,3) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
please use the timeout and retry parameter.
|
|
||
| val metaAddress = addresses.map(address => new HostAddress(address._1, address._2)).asJava | ||
| val client = new MetaClient(metaAddress) | ||
| val client = new MetaClient(metaAddress,6000,3,3) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
the timeout and retry number should be parameter
| private val DEFAULT_EXECUTION_RETRY_SIZE = 3 | ||
| val metaAddress = addresses.map(address => new HostAddress(address._1, address._2)).asJava | ||
| val client = new MetaClient(metaAddress) | ||
| val client = new MetaClient(metaAddress,DEFAULT_TIMEOUT_MS,DEFAULT_CONNECTION_RETRY_SIZE,DEFAULT_EXECUTION_RETRY_SIZE) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
we should get timeout and retry parameter from NebulaConnectionConfig
|
Thanks for your contribution for Nebula-Exchange and Nebula-Spark-Connector, now this repo has been split into three different repos, could you please submit two pr to repo https://github.com/vesoft-inc/nebula-exchang and repo https://github.com/vesoft-inc/nebula-spark-connector. |
meta client connection , 1 second will often timeout, Increase to 6 seconds。