You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kyuubi.apache.org by fe...@apache.org on 2023/05/16 06:48:38 UTC

[kyuubi] branch master updated: [KYUUBI #4842] [MINOR] Fix typo in etcd client config

This is an automated email from the ASF dual-hosted git repository.

feiwang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/kyuubi.git


The following commit(s) were added to refs/heads/master by this push:
     new 2e3919f5a [KYUUBI #4842] [MINOR] Fix typo in etcd client config
2e3919f5a is described below

commit 2e3919f5a614e40abc6dfc857352a8828d496907
Author: fwang12 <fw...@ebay.com>
AuthorDate: Tue May 16 14:48:28 2023 +0800

    [KYUUBI #4842] [MINOR] Fix typo in etcd client config
    
    ### _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 <fw...@ebay.com>
    Signed-off-by: fwang12 <fw...@ebay.com>
---
 .../main/scala/org/apache/kyuubi/ha/HighAvailabilityConf.scala    | 4 ++--
 .../org/apache/kyuubi/ha/client/etcd/EtcdDiscoveryClient.scala    | 8 ++++----
 2 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/kyuubi-ha/src/main/scala/org/apache/kyuubi/ha/HighAvailabilityConf.scala b/kyuubi-ha/src/main/scala/org/apache/kyuubi/ha/HighAvailabilityConf.scala
index 148a21e4d..eba069da2 100644
--- a/kyuubi-ha/src/main/scala/org/apache/kyuubi/ha/HighAvailabilityConf.scala
+++ b/kyuubi-ha/src/main/scala/org/apache/kyuubi/ha/HighAvailabilityConf.scala
@@ -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")
diff --git a/kyuubi-ha/src/main/scala/org/apache/kyuubi/ha/client/etcd/EtcdDiscoveryClient.scala b/kyuubi-ha/src/main/scala/org/apache/kyuubi/ha/client/etcd/EtcdDiscoveryClient.scala
index 80a70f2f2..548628a88 100644
--- a/kyuubi-ha/src/main/scala/org/apache/kyuubi/ha/client/etcd/EtcdDiscoveryClient.scala
+++ b/kyuubi-ha/src/main/scala/org/apache/kyuubi/ha/client/etcd/EtcdDiscoveryClient.scala
@@ -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))