Repository: hive Updated Branches: refs/heads/master 1eea5a80d -> e709f7a89
Advertising
HIVE-19106 : Hive ZooKeeper Locking - Throw and Log (Igor Kryvenko via Ashutosh Chauhan) Signed-off-by: Ashutosh Chauhan <hashut...@apache.org> Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/e709f7a8 Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/e709f7a8 Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/e709f7a8 Branch: refs/heads/master Commit: e709f7a8911a97c6ae22310035ffedfd103ca3af Parents: 1eea5a8 Author: Igor Kryvenko <kryvenko7i...@gmail.com> Authored: Sat Apr 14 10:09:11 2018 -0700 Committer: Ashutosh Chauhan <hashut...@apache.org> Committed: Sat Apr 14 10:09:11 2018 -0700 ---------------------------------------------------------------------- .../hive/ql/lockmgr/zookeeper/ZooKeeperHiveLockManager.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/e709f7a8/ql/src/java/org/apache/hadoop/hive/ql/lockmgr/zookeeper/ZooKeeperHiveLockManager.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/lockmgr/zookeeper/ZooKeeperHiveLockManager.java b/ql/src/java/org/apache/hadoop/hive/ql/lockmgr/zookeeper/ZooKeeperHiveLockManager.java index 1d8c16b..141cbc9 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/lockmgr/zookeeper/ZooKeeperHiveLockManager.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/lockmgr/zookeeper/ZooKeeperHiveLockManager.java @@ -491,8 +491,8 @@ public class ZooKeeperHiveLockManager implements HiveLockManager { } catch (Exception e) { if (tryNum >= numRetriesForUnLock) { String name = ((ZooKeeperHiveLock)hiveLock).getPath(); - LOG.error("Node " + name + " can not be deleted after " + numRetriesForUnLock + " attempts."); - throw new LockException(e); + throw new LockException("Node " + name + " can not be deleted after " + numRetriesForUnLock + " attempts.", + e); } } } while (tryNum < numRetriesForUnLock);
