You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by su...@apache.org on 2017/05/18 05:17:47 UTC
hive git commit: HIVE-16700: Log ZK discovery info (hostname & port)
for HTTP mode when connection is established (Chao Sun,
reviewed by Xuefu Zhang)
Repository: hive
Updated Branches:
refs/heads/master 1f49635e8 -> 89699ef4b
HIVE-16700: Log ZK discovery info (hostname & port) for HTTP mode when connection is established (Chao Sun, reviewed by Xuefu Zhang)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/89699ef4
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/89699ef4
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/89699ef4
Branch: refs/heads/master
Commit: 89699ef4be80150cc31f89eefaf9d3db20e30e6e
Parents: 1f49635
Author: Chao Sun <su...@apache.org>
Authored: Wed May 17 14:22:02 2017 -0700
Committer: Chao Sun <su...@apache.org>
Committed: Wed May 17 22:15:40 2017 -0700
----------------------------------------------------------------------
.../java/org/apache/hive/jdbc/HiveConnection.java | 16 ++++++++--------
1 file changed, 8 insertions(+), 8 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/89699ef4/jdbc/src/java/org/apache/hive/jdbc/HiveConnection.java
----------------------------------------------------------------------
diff --git a/jdbc/src/java/org/apache/hive/jdbc/HiveConnection.java b/jdbc/src/java/org/apache/hive/jdbc/HiveConnection.java
index 8b37ab0..73e4734 100644
--- a/jdbc/src/java/org/apache/hive/jdbc/HiveConnection.java
+++ b/jdbc/src/java/org/apache/hive/jdbc/HiveConnection.java
@@ -303,14 +303,14 @@ public class HiveConnection implements java.sql.Connection {
private void openTransport() throws Exception {
- assumeSubject =
- JdbcConnectionParams.AUTH_KERBEROS_AUTH_TYPE_FROM_SUBJECT.equals(sessConfMap
- .get(JdbcConnectionParams.AUTH_KERBEROS_AUTH_TYPE));
- transport = isHttpTransportMode() ? createHttpTransport() : createBinaryTransport();
- if (!transport.isOpen()) {
- transport.open();
- logZkDiscoveryMessage("Connected to " + connParams.getHost() + ":" + connParams.getPort());
- }
+ assumeSubject =
+ JdbcConnectionParams.AUTH_KERBEROS_AUTH_TYPE_FROM_SUBJECT.equals(sessConfMap
+ .get(JdbcConnectionParams.AUTH_KERBEROS_AUTH_TYPE));
+ transport = isHttpTransportMode() ? createHttpTransport() : createBinaryTransport();
+ if (!transport.isOpen()) {
+ transport.open();
+ }
+ logZkDiscoveryMessage("Connected to " + connParams.getHost() + ":" + connParams.getPort());
}
public String getConnectedUrl() {