diff --git a/jdbc/src/java/org/apache/hive/jdbc/HiveConnection.java b/jdbc/src/java/org/apache/hive/jdbc/HiveConnection.java index 70cc34d..9f457a2 100644 --- a/jdbc/src/java/org/apache/hive/jdbc/HiveConnection.java +++ b/jdbc/src/java/org/apache/hive/jdbc/HiveConnection.java @@ -171,9 +171,13 @@ public HiveConnection(String uri, Properties info) throws SQLException { // sess_var_list -> sessConfMap // hive_conf_list -> hiveConfMap // hive_var_list -> hiveVarMap - host = Utils.getCanonicalHostName(connParams.getHost()); - port = connParams.getPort(); sessConfMap = connParams.getSessionVars(); + if (isKerberosAuthMode()) { + host = Utils.getCanonicalHostName(connParams.getHost()); + } else { + host = connParams.getHost(); + } + port = connParams.getPort(); isEmbeddedMode = connParams.isEmbeddedMode(); if (sessConfMap.containsKey(JdbcConnectionParams.FETCH_SIZE)) { @@ -241,7 +245,11 @@ public HiveConnection(String uri, Properties info) throws SQLException { } // Update with new values jdbcUriString = connParams.getJdbcUriString(); - host = Utils.getCanonicalHostName(connParams.getHost()); + if (isKerberosAuthMode()) { + host = Utils.getCanonicalHostName(connParams.getHost()); + } else { + host = connParams.getHost(); + } port = connParams.getPort(); } else { errMsg = warnMsg;