diff --git ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java index ff875df..5c69fb6 100644 --- ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java +++ ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java @@ -400,7 +400,7 @@ public String getSessionId() { * @return transaction manager * @throws LockException */ - public HiveTxnManager initTxnMgr(HiveConf conf) throws LockException { + public synchronized HiveTxnManager initTxnMgr(HiveConf conf) throws LockException { if (txnMgr == null) { txnMgr = TxnManagerFactory.getTxnManagerFactory().getTxnManager(conf); }