diff --git a/beeline/src/main/resources/beeline-log4j2.xml b/beeline/src/main/resources/beeline-log4j2.xml
index a64f55e..55ec0f5 100644
--- a/beeline/src/main/resources/beeline-log4j2.xml
+++ b/beeline/src/main/resources/beeline-log4j2.xml
@@ -34,6 +34,8 @@
+
+
-
+
\ No newline at end of file
diff --git a/jdbc/src/java/org/apache/hive/jdbc/HiveConnection.java b/jdbc/src/java/org/apache/hive/jdbc/HiveConnection.java
index 2969bc6..e7cf0c8 100644
--- a/jdbc/src/java/org/apache/hive/jdbc/HiveConnection.java
+++ b/jdbc/src/java/org/apache/hive/jdbc/HiveConnection.java
@@ -205,16 +205,14 @@ private void openTransport() throws SQLException {
.get(JdbcConnectionParams.AUTH_KERBEROS_AUTH_TYPE));
transport = isHttpTransportMode() ? createHttpTransport() : createBinaryTransport();
if (!transport.isOpen()) {
- LOG.info("Will try to open client transport with JDBC Uri: " + jdbcUriString);
transport.open();
+ logZkDiscoveryMessage("Connected to " + connParams.getHost() + ":" + connParams.getPort());
}
break;
} catch (TTransportException e) {
- LOG.info("Could not open client transport with JDBC Uri: " + jdbcUriString);
// We'll retry till we exhaust all HiveServer2 nodes from ZooKeeper
- if ((sessConfMap.get(JdbcConnectionParams.SERVICE_DISCOVERY_MODE) != null)
- && (JdbcConnectionParams.SERVICE_DISCOVERY_MODE_ZOOKEEPER.equalsIgnoreCase(sessConfMap
- .get(JdbcConnectionParams.SERVICE_DISCOVERY_MODE)))) {
+ if (isZkDynamicDiscoveryMode()) {
+ LOG.info("Failed to connect to " + connParams.getHost() + ":" + connParams.getPort());
try {
// Update jdbcUriString, host & port variables in connParams
// Throw an exception if all HiveServer2 nodes have been exhausted,
@@ -229,7 +227,6 @@ private void openTransport() throws SQLException {
jdbcUriString = connParams.getJdbcUriString();
host = connParams.getHost();
port = connParams.getPort();
- LOG.info("Will retry opening client transport");
} else {
LOG.info("Transport Used for JDBC connection: " +
sessConfMap.get(JdbcConnectionParams.TRANSPORT_MODE));
@@ -651,6 +648,18 @@ private boolean isHttpTransportMode() {
return false;
}
+ private boolean isZkDynamicDiscoveryMode() {
+ return (sessConfMap.get(JdbcConnectionParams.SERVICE_DISCOVERY_MODE) != null)
+ && (JdbcConnectionParams.SERVICE_DISCOVERY_MODE_ZOOKEEPER.equalsIgnoreCase(sessConfMap
+ .get(JdbcConnectionParams.SERVICE_DISCOVERY_MODE)));
+ }
+
+ private void logZkDiscoveryMessage(String message) {
+ if (isZkDynamicDiscoveryMode()) {
+ LOG.info(message);
+ }
+ }
+
/**
* Lookup varName in sessConfMap, if its null or empty return the default
* value varDefault