svn commit: r1562236 - /hive/trunk/jdbc/src/java/org/apache/hive/jdbc/HiveConnection.java

[thejas]

Author: thejas
Date: Tue Jan 28 21:23:09 2014
New Revision: 1562236

URL: http://svn.apache.org/r1562236
Log:
HIVE-6249 : HiveServer2 JDBC SSL binary client transport should not call a 
TTransport#open  (Vaibhav Gumashta via Thejas Nair)

Modified:
    hive/trunk/jdbc/src/java/org/apache/hive/jdbc/HiveConnection.java

Modified: hive/trunk/jdbc/src/java/org/apache/hive/jdbc/HiveConnection.java
URL: 
http://svn.apache.org/viewvc/hive/trunk/jdbc/src/java/org/apache/hive/jdbc/HiveConnection.java?rev=1562236&r1=1562235&r2=1562236&view=diff
==============================================================================
--- hive/trunk/jdbc/src/java/org/apache/hive/jdbc/HiveConnection.java (original)
+++ hive/trunk/jdbc/src/java/org/apache/hive/jdbc/HiveConnection.java Tue Jan 
28 21:23:09 2014
@@ -131,6 +131,8 @@ public class HiveConnection implements j
       }
       // open the client transport
       openTransport();
+      // set up the client
+      client = new TCLIService.Client(new TBinaryProtocol(transport));
     }
 
     // add supported protocols
@@ -149,10 +151,10 @@ public class HiveConnection implements j
 
   private void openTransport() throws SQLException {
     transport = isHttpTransportMode() ? createHttpTransport() : 
createBinaryTransport();
-    TProtocol protocol = new TBinaryProtocol(transport);
-    client = new TCLIService.Client(protocol);
     try {
-      transport.open();
+      if (!transport.isOpen()) {
+        transport.open(); 
+      }
     } catch (TTransportException e) {
       throw new SQLException("Could not open connection to "
           + jdbcURI + ": " + e.getMessage(), " 08S01", e);