diff --git a/ql/src/java/org/apache/hadoop/hive/ql/lockmgr/HiveTxnManagerImpl.java b/ql/src/java/org/apache/hadoop/hive/ql/lockmgr/HiveTxnManagerImpl.java index 623b0376c6..44f58fd664 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/lockmgr/HiveTxnManagerImpl.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/lockmgr/HiveTxnManagerImpl.java @@ -100,7 +100,7 @@ public int lockTable(Hive db, LockTableDesc lockTbl) throws HiveException { conf); if (partSpec == null) { - HiveLock lck = lockMgr.lock(new HiveLockObject(tbl, lockData), mode, true); + HiveLock lck = lockMgr.lock(new HiveLockObject(tbl, lockData), mode, false); if (lck == null) { return 1; } @@ -112,7 +112,7 @@ public int lockTable(Hive db, LockTableDesc lockTbl) throws HiveException { throw new HiveException("Partition " + partSpec + " for table " + tabName + " does not exist"); } - HiveLock lck = lockMgr.lock(new HiveLockObject(par, lockData), mode, true); + HiveLock lck = lockMgr.lock(new HiveLockObject(par, lockData), mode, false); if (lck == null) { return 1; } @@ -157,7 +157,7 @@ public int lockDatabase(Hive hiveDB, LockDatabaseDesc lockDb) throws HiveExcepti String.valueOf(System.currentTimeMillis()), "EXPLICIT", lockDb.getQueryStr(), conf); - HiveLock lck = lockMgr.lock(new HiveLockObject(dbObj.getName(), lockData), mode, true); + HiveLock lck = lockMgr.lock(new HiveLockObject(dbObj.getName(), lockData), mode, false); if (lck == null) { return 1; }