diff --git jdbc/src/java/org/apache/hive/jdbc/Utils.java jdbc/src/java/org/apache/hive/jdbc/Utils.java index eb7c0c71bc..9074a96381 100644 --- jdbc/src/java/org/apache/hive/jdbc/Utils.java +++ jdbc/src/java/org/apache/hive/jdbc/Utils.java @@ -680,6 +680,7 @@ static boolean updateConnParamsFromZooKeeper(JdbcConnectionParams connParams) { connParams.getRejectedHostZnodePaths().add(connParams.getCurrentHostZnodePath()); String oldServerHost = connParams.getHost(); int oldServerPort = connParams.getPort(); + connParams.setPort(-1); // Update connection params (including host, port) from ZooKeeper try { ZooKeeperHiveClientHelper.configureConnParams(connParams);