apache/kyuubi
1
0
Fork 0
Code Issues Pull Requests Actions 5 Packages Projects Releases Wiki Activity

[KYUUBI #4842] [MINOR] Fix typo in etcd client config

Browse Source 
### _Why are the changes needed?_

Fix typo.
### _How was this patch tested?_
- [ ] Add some test cases that check the changes thoroughly including negative and positive cases if possible

- [ ] Add screenshots for manual tests if appropriate

- [x] [Run test](https://kyuubi.readthedocs.io/en/master/develop_tools/testing.html#running-tests) locally before make a pull request

Closes #4842 from turboFei/etcd_typo.

Closes #4842

218374976 [fwang12] fix typo for etcd client

Authored-by: fwang12 <fwang12@ebay.com>
Signed-off-by: fwang12 <fwang12@ebay.com>
This commit is contained in:
fwang12 2023-05-16 14:48:28 +08:00
parent f20f61e686
commit 2e3919f5a6
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
kyuubi-ha/src/main/scala/org/apache/kyuubi/ha/HighAvailabilityConf.scala
View File

@ -209,14 +209,14 @@ object HighAvailabilityConf {
.stringConf
.createOptional
val HA_ETCD_SSL_CLINET_CRT_PATH: OptionalConfigEntry[String] =
val HA_ETCD_SSL_CLIENT_CRT_PATH: OptionalConfigEntry[String] =
buildConf("kyuubi.ha.etcd.ssl.client.certificate.path")
.doc("Where the etcd SSL certificate file is stored.")
.version("1.6.0")
.stringConf
.createOptional
val HA_ETCD_SSL_CLINET_KEY_PATH: OptionalConfigEntry[String] =
val HA_ETCD_SSL_CLIENT_KEY_PATH: OptionalConfigEntry[String] =
buildConf("kyuubi.ha.etcd.ssl.client.key.path")
.doc("Where the etcd SSL key file is stored.")
.version("1.6.0")

8
kyuubi-ha/src/main/scala/org/apache/kyuubi/ha/client/etcd/EtcdDiscoveryClient.scala
View File

@ -74,10 +74,10 @@ class EtcdDiscoveryClient(conf: KyuubiConf) extends DiscoveryClient {
} else {
val caPath = conf.getOption(HA_ETCD_SSL_CA_PATH.key).getOrElse(
throw new IllegalArgumentException(s"${HA_ETCD_SSL_CA_PATH.key} is not defined"))
val crtPath = conf.getOption(HA_ETCD_SSL_CLINET_CRT_PATH.key).getOrElse(
throw new IllegalArgumentException(s"${HA_ETCD_SSL_CLINET_CRT_PATH.key} is not defined"))
val keyPath = conf.getOption(HA_ETCD_SSL_CLINET_KEY_PATH.key).getOrElse(
throw new IllegalArgumentException(s"${HA_ETCD_SSL_CLINET_KEY_PATH.key} is not defined"))
val crtPath = conf.getOption(HA_ETCD_SSL_CLIENT_CRT_PATH.key).getOrElse(
throw new IllegalArgumentException(s"${HA_ETCD_SSL_CLIENT_CRT_PATH.key} is not defined"))
val keyPath = conf.getOption(HA_ETCD_SSL_CLIENT_KEY_PATH.key).getOrElse(
throw new IllegalArgumentException(s"${HA_ETCD_SSL_CLIENT_KEY_PATH.key} is not defined"))
val context = GrpcSslContexts.forClient()
.trustManager(new File(caPath))