diff --git metastore/src/java/org/apache/hadoop/hive/metastore/txn/TxnHandler.java metastore/src/java/org/apache/hadoop/hive/metastore/txn/TxnHandler.java index bcb0342..b121644 100644 --- metastore/src/java/org/apache/hadoop/hive/metastore/txn/TxnHandler.java +++ metastore/src/java/org/apache/hadoop/hive/metastore/txn/TxnHandler.java @@ -18,7 +18,6 @@ package org.apache.hadoop.hive.metastore.txn; import com.google.common.annotations.VisibleForTesting; -import com.google.common.util.concurrent.Service; import com.jolbox.bonecp.BoneCPConfig; import com.jolbox.bonecp.BoneCPDataSource; import org.apache.commons.dbcp.ConnectionFactory; @@ -3254,9 +3253,8 @@ public LockHandle acquireLock(String key) throws MetaException { } } catch(RetryException ex) { - acquireLock(key); + return acquireLock(key); } - throw new MetaException("This can't happen because checkRetryable() has a retry limit"); } public void acquireLock(String key, LockHandle handle) { //the idea is that this will use LockHandle.dbConn