hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gunt...@apache.org
Subject svn commit: r1613335 [12/12] - in /hive/branches/cbo: ./ beeline/src/java/org/apache/hive/beeline/ common/src/java/org/apache/hadoop/hive/common/cli/ common/src/java/org/apache/hadoop/hive/conf/ common/src/java/org/apache/hive/common/util/ conf/ contri...
Date Fri, 25 Jul 2014 00:38:28 GMT
Modified: hive/branches/cbo/service/src/java/org/apache/hive/service/cli/session/SessionManager.java
URL: http://svn.apache.org/viewvc/hive/branches/cbo/service/src/java/org/apache/hive/service/cli/session/SessionManager.java?rev=1613335&r1=1613334&r2=1613335&view=diff
==============================================================================
--- hive/branches/cbo/service/src/java/org/apache/hive/service/cli/session/SessionManager.java
(original)
+++ hive/branches/cbo/service/src/java/org/apache/hive/service/cli/session/SessionManager.java
Fri Jul 25 00:38:23 2014
@@ -47,6 +47,7 @@ import org.apache.hive.service.cli.thrif
 public class SessionManager extends CompositeService {
 
   private static final Log LOG = LogFactory.getLog(CompositeService.class);
+  public static final String HIVERCFILE = ".hiverc";
   private HiveConf hiveConf;
   private final Map<SessionHandle, HiveSession> handleToSession =
       new ConcurrentHashMap<SessionHandle, HiveSession>();
@@ -122,15 +123,16 @@ public class SessionManager extends Comp
     HiveSession session;
     if (withImpersonation) {
       HiveSessionImplwithUGI hiveSessionUgi = new HiveSessionImplwithUGI(protocol, username,
password,
-        hiveConf, sessionConf, TSetIpAddressProcessor.getUserIpAddress(), delegationToken);
+        hiveConf, TSetIpAddressProcessor.getUserIpAddress(), delegationToken);
       session = HiveSessionProxy.getProxy(hiveSessionUgi, hiveSessionUgi.getSessionUgi());
       hiveSessionUgi.setProxySession(session);
     } else {
-      session = new HiveSessionImpl(protocol, username, password, hiveConf, sessionConf,
+      session = new HiveSessionImpl(protocol, username, password, hiveConf,
           TSetIpAddressProcessor.getUserIpAddress());
     }
     session.setSessionManager(this);
     session.setOperationManager(operationManager);
+    session.initialize(sessionConf);
     session.open();
     handleToSession.put(session.getSessionHandle(), session);
 



Mime
View raw message