Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 3F9D6200BA1 for ; Mon, 17 Oct 2016 14:47:07 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 3E3AF160AEC; Mon, 17 Oct 2016 12:47:07 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 8692A160AE5 for ; Mon, 17 Oct 2016 14:47:06 +0200 (CEST) Received: (qmail 16256 invoked by uid 500); 17 Oct 2016 12:47:05 -0000 Mailing-List: contact dev-help@hive.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@hive.apache.org Delivered-To: mailing list dev@hive.apache.org Received: (qmail 16234 invoked by uid 99); 17 Oct 2016 12:47:04 -0000 Received: from reviews-vm.apache.org (HELO reviews.apache.org) (140.211.11.40) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 17 Oct 2016 12:47:04 +0000 Received: from reviews.apache.org (localhost [127.0.0.1]) by reviews.apache.org (Postfix) with ESMTP id AC2FF2D0F20; Mon, 17 Oct 2016 12:47:03 +0000 (UTC) Content-Type: multipart/alternative; boundary="===============6802097742182845169==" MIME-Version: 1.0 Subject: Re: Review Request 52923: HIVE-14979 Removing stale Zookeeper locks at HiveServer2 initialization From: Barna Zsombor Klara To: Barna Zsombor Klara , Ashutosh Chauhan , Marta Kuczora , Miklos Csanady , namit jain , Sergio Pena Cc: Peter Vary , hive Date: Mon, 17 Oct 2016 12:47:03 -0000 Message-ID: <20161017124703.14471.60402@reviews.apache.org> X-ReviewBoard-URL: https://reviews.apache.org/ Auto-Submitted: auto-generated Sender: Barna Zsombor Klara X-ReviewGroup: hive X-Auto-Response-Suppress: DR, RN, OOF, AutoReply X-ReviewRequest-URL: https://reviews.apache.org/r/52923/ X-Sender: Barna Zsombor Klara References: <20161017093435.5284.5547@reviews.apache.org> In-Reply-To: <20161017093435.5284.5547@reviews.apache.org> Reply-To: Barna Zsombor Klara X-ReviewRequest-Repository: hive-git archived-at: Mon, 17 Oct 2016 12:47:07 -0000 --===============6802097742182845169== MIME-Version: 1.0 Content-Type: text/plain; charset="utf-8" Content-Transfer-Encoding: 7bit ----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/52923/#review152862 ----------------------------------------------------------- Thanks for the patch Peter, looks good. I only have some questions/comments, but no concrete issues to open. common/src/java/org/apache/hadoop/hive/conf/HiveConf.java (line 1770) nit1: I wouldn't use a semi-colon, only a comma. nit2: Whether to release stale zookeeper locks at HiveServer2 startup time which *were* nit3: release every *lock* created by these servers too ql/src/java/org/apache/hadoop/hive/ql/lockmgr/zookeeper/ZooKeeperHiveLockManager.java (line 648) What is the reason for this null check? ql/src/test/org/apache/hadoop/hive/ql/lockmgr/zookeeper/TestZookeeperLockManager.java (line 68) Do we still need this infinite loop? What if we get something more permanent than a transient bind exception, should we retry for every exception and for inifity? service/src/java/org/apache/hive/service/server/HiveServer2.java (line 670) Any reason we are biased towards the ZooKeeperHiveLockManager? I would maybe call the method releaseStaleLocks, put it into the HiveLockManager interface and then leave it to the implementation to see if those are identified by IP and released per HS2 instance or dealt with otherwise. - Barna Zsombor Klara On Oct. 17, 2016, 9:34 a.m., Peter Vary wrote: > > ----------------------------------------------------------- > This is an automatically generated e-mail. To reply, visit: > https://reviews.apache.org/r/52923/ > ----------------------------------------------------------- > > (Updated Oct. 17, 2016, 9:34 a.m.) > > > Review request for hive, Ashutosh Chauhan, Marta Kuczora, Miklos Csanady, namit jain, Sergio Pena, and Barna Zsombor Klara. > > > Bugs: HIVE-14979 > https://issues.apache.org/jira/browse/HIVE-14979 > > > Repository: hive-git > > > Description > ------- > > Adding a new configuration option to HiveConf to signal whether stale lock removal is requested on startup. > Adding a new method to ZooKeeperHiveLockManager to remove stale locks > Modifying the HiveServer2 to instantiate a lock manager and call the new method if defined by the configuration. > > Please take extra care when reviewing these: > - Modifying the lock fetching method to use the clientIp from the lock, and not update with the current ip - Not sure why it was done before > - Instantiation of the lock manager - I might not chose the best method for it > > Open for any suggestions :) > > Thanks, > Peter > > > Diffs > ----- > > common/src/java/org/apache/hadoop/hive/conf/HiveConf.java 8ffae3b > ql/src/java/org/apache/hadoop/hive/ql/lockmgr/zookeeper/ZooKeeperHiveLockManager.java 14d0ef4 > ql/src/test/org/apache/hadoop/hive/ql/lockmgr/zookeeper/TestZookeeperLockManager.java 3f9926e > service/src/java/org/apache/hive/service/server/HiveServer2.java 590b1f3 > > Diff: https://reviews.apache.org/r/52923/diff/ > > > Testing > ------- > > Created 2 unit test cases: > - Removing own locks > - Not removing other server's locks > > Manually tested the Lock manager instantiation method on HiveServer2 > > > Thanks, > > Peter Vary > > --===============6802097742182845169==--