[
https://issues.apache.org/jira/browse/HIVE-5732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Brock Noland updated HIVE-5732:
-------------------------------
Resolution: Fixed
Fix Version/s: 0.13.0
Status: Resolved (was: Patch Available)
Committed to trunk! Thank you 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
> Fix For: 0.13.0
>
> Attachments: HIVE-5732.1.patch.txt
>
>
> {noformat}
> 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);
> }
> {noformat}
--
This message was sent by Atlassian JIRA
(v6.1#6144)
