You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@hive.apache.org by "Schubert Zhang (JIRA)" <ji...@apache.org> on 2013/11/02 13:18:17 UTC
[jira] [Created] (HIVE-5732) HiveServer2: Duplicated new
OperationManager in SessionManager
Schubert Zhang created HIVE-5732:
------------------------------------
Summary: HiveServer2: Duplicated new OperationManager in SessionManager
Key: HIVE-5732
URL: https://issues.apache.org/jira/browse/HIVE-5732
Project: Hive
Issue Type: Bug
Affects Versions: 0.12.0
Reporter: Schubert Zhang
Priority: Trivial
public class SessionManager extends CompositeService {
private static final Log LOG = LogFactory.getLog(CompositeService.class);
private HiveConf hiveConf;
private final Map<SessionHandle, HiveSession> handleToSession = new HashMap<SessionHandle, HiveSession>();
private OperationManager operationManager = new OperationManager();
private static final Object sessionMapLock = new Object();
private ExecutorService backgroundOperationPool;
public SessionManager() {
super("SessionManager");
}
@Override
public synchronized void init(HiveConf hiveConf) {
this.hiveConf = hiveConf;
operationManager = new OperationManager();
int backgroundPoolSize = hiveConf.getIntVar(ConfVars.HIVE_SERVER2_ASYNC_EXEC_THREADS);
LOG.info("HiveServer2: Async execution pool size" + backgroundPoolSize);
backgroundOperationPool = Executors.newFixedThreadPool(backgroundPoolSize);
addService(operationManager);
super.init(hiveConf);
}
--
This message was sent by Atlassian JIRA
(v6.1#6144)