You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@hive.apache.org by "Navis (JIRA)" <ji...@apache.org> on 2013/11/12 08:10:19 UTC
[jira] [Assigned] (HIVE-5732) HiveServer2: Duplicated new
OperationManager in SessionManager
[ https://issues.apache.org/jira/browse/HIVE-5732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Navis reassigned HIVE-5732:
---------------------------
Assignee: Navis
> 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
> Assignee: Navis
> Priority: Trivial
> Attachments: HIVE-5732.1.patch.txt
>
>
> 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)