fix(hive): config name matching

raycursive · raycursive · commit 52f2c229de16 · 2021-07-07T20:08:48.000+08:00
diff --git a/hive/src/HiveConnector.kt b/hive/src/HiveConnector.kt
@@ -33,8 +33,8 @@ class HiveConnector : JDBCConnector() {
     override val transactionIsolationLevel = Connection.TRANSACTION_READ_UNCOMMITTED
 
     override fun buildConnectionStr(profile: Profile): String {
-        val endpoint = profile.configs["endpoint"]
-        val port = profile.configs["port"]
+        val endpoint = profile.configs["Endpoint"]
+        val port = profile.configs["Port"]
         return "jdbc:hive2://${endpoint}:${port}"
     }
 

Original file line number	Diff line number	Diff line change
`@@ -33,8 +33,8 @@ class HiveConnector : JDBCConnector() {`
`33`	`33`	`override val transactionIsolationLevel = Connection.TRANSACTION_READ_UNCOMMITTED`
`34`	`34`
`35`	`35`	`override fun buildConnectionStr(profile: Profile): String {`
`36`		`- val endpoint = profile.configs["endpoint"]`
`37`		`- val port = profile.configs["port"]`
	`36`	`+ val endpoint = profile.configs["Endpoint"]`
	`37`	`+ val port = profile.configs["Port"]`
`38`	`38`	`return "jdbc:hive2://${endpoint}:${port}"`
`39`	`39`	`}`
`40`	`40`