From 4f76373b7f32a984ddbbb3f3d8ef2da794e70075 Mon Sep 17 00:00:00 2001 From: wforget <643348094@qq.com> Date: Wed, 8 May 2024 10:27:54 +0800 Subject: [PATCH] [KYUUBI #6346] Change Kyuubi JDBC Driver default port and make it effective MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit # :mag: Description ## Issue References ๐Ÿ”— This pull request fixes #6346 ## Describe Your Solution ๐Ÿ”ง Change Kyuubi JDBC Driver default port and make it effective. ## Types of changes :bookmark: - [X] Bugfix (non-breaking change which fixes an issue) - [ ] New feature (non-breaking change which adds functionality) - [ ] Breaking change (fix or feature that would cause existing functionality to change) ## Test Plan ๐Ÿงช #### Behavior Without This Pull Request :coffin: #### Behavior With This Pull Request :tada: #### Related Unit Tests --- # Checklist ๐Ÿ“ - [X] This patch was not authored or co-authored using [Generative Tooling](https://www.apache.org/legal/generative-tooling.html) **Be nice. Be informative.** Closes #6347 from wForget/KYUUBI-6346. Closes #6346 0a3085205 [wforget] [KYUUBI #6346] Change Kyuubi JDBC Driver default port and make it effective Authored-by: wforget <643348094@qq.com> Signed-off-by: wforget <643348094@qq.com> --- .../src/main/java/org/apache/kyuubi/jdbc/hive/Utils.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/kyuubi-hive-jdbc/src/main/java/org/apache/kyuubi/jdbc/hive/Utils.java b/kyuubi-hive-jdbc/src/main/java/org/apache/kyuubi/jdbc/hive/Utils.java index 881a96027..b9f256f69 100644 --- a/kyuubi-hive-jdbc/src/main/java/org/apache/kyuubi/jdbc/hive/Utils.java +++ b/kyuubi-hive-jdbc/src/main/java/org/apache/kyuubi/jdbc/hive/Utils.java @@ -42,7 +42,7 @@ public class Utils { Arrays.asList("jdbc:hive2://", "jdbc:kyuubi://"); /** If host is provided, without a port. */ - static final String DEFAULT_PORT = "10000"; + static final String DEFAULT_PORT = "10009"; // To parse the intermediate URI as a Java URI, we'll give a dummy authority(dummyhost:00000). // Later, we'll substitute the dummy authority for a resolved authority. static final String dummyAuthorityString = "dummyhost:00000"; @@ -381,8 +381,8 @@ public class Utils { if (port <= 0) { port = Integer.parseInt(Utils.DEFAULT_PORT); } - connParams.setHost(jdbcBaseURI.getHost()); - connParams.setPort(jdbcBaseURI.getPort()); + connParams.setHost(host); + connParams.setPort(port); } // We check for invalid host, port while configuring connParams with configureConnParams() authorityStr = connParams.getHost() + ":" + connParams.getPort();