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);
 


Reply via email to