You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by na...@apache.org on 2012/10/06 14:29:53 UTC
svn commit: r1395026 -
/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/lockmgr/zookeeper/ZooKeeperHiveLockManager.java
Author: namit
Date: Sat Oct 6 12:29:53 2012
New Revision: 1395026
URL: http://svn.apache.org/viewvc?rev=1395026&view=rev
Log:
HIVE-3533 ZooKeeperHiveLockManager does not respect the option to keep locks alive even after
the current session has closed (Matt Martin via namit)
Modified:
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/lockmgr/zookeeper/ZooKeeperHiveLockManager.java
Modified: hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/lockmgr/zookeeper/ZooKeeperHiveLockManager.java
URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/lockmgr/zookeeper/ZooKeeperHiveLockManager.java?rev=1395026&r1=1395025&r2=1395026&view=diff
==============================================================================
--- hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/lockmgr/zookeeper/ZooKeeperHiveLockManager.java (original)
+++ hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/lockmgr/zookeeper/ZooKeeperHiveLockManager.java Sat Oct 6 12:29:53 2012
@@ -217,7 +217,7 @@ public class ZooKeeperHiveLockManager im
HiveLock lock = null;
try {
- lock = lock(lockObject.getObj(), lockObject.getMode(), false, true);
+ lock = lock(lockObject.getObj(), lockObject.getMode(), keepAlive, true);
} catch (LockException e) {
console.printError("Error in acquireLocks..." );
LOG.error("Error in acquireLocks...", e);