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 B7FB3200C41 for ; Fri, 24 Mar 2017 22:27:25 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id B690A160B93; Fri, 24 Mar 2017 21:27:25 +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 07852160B75 for ; Fri, 24 Mar 2017 22:27:24 +0100 (CET) Received: (qmail 82824 invoked by uid 500); 24 Mar 2017 21:27:24 -0000 Mailing-List: contact reviews-help@impala.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Delivered-To: mailing list reviews@impala.incubator.apache.org Received: (qmail 82812 invoked by uid 99); 24 Mar 2017 21:27:24 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd1-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 24 Mar 2017 21:27:23 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd1-us-west.apache.org (ASF Mail Server at spamd1-us-west.apache.org) with ESMTP id 99609C1A57 for ; Fri, 24 Mar 2017 21:27:23 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 0.363 X-Spam-Level: X-Spam-Status: No, score=0.363 tagged_above=-999 required=6.31 tests=[RDNS_DYNAMIC=0.363, SPF_PASS=-0.001, URIBL_BLOCKED=0.001] autolearn=disabled Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id lsqmEOoRx3G3 for ; Fri, 24 Mar 2017 21:27:23 +0000 (UTC) Received: from ip-10-146-233-104.ec2.internal (ec2-75-101-130-251.compute-1.amazonaws.com [75.101.130.251]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTPS id B28BB5FBA1 for ; Fri, 24 Mar 2017 21:27:22 +0000 (UTC) Received: from localhost (localhost [127.0.0.1]) by ip-10-146-233-104.ec2.internal (8.14.4/8.14.4) with ESMTP id v2OLRKC1026027; Fri, 24 Mar 2017 21:27:20 GMT Message-Id: <201703242127.v2OLRKC1026027@ip-10-146-233-104.ec2.internal> Date: Fri, 24 Mar 2017 21:27:19 +0000 From: "Dimitris Tsirogiannis (Code Review)" To: impala-cr@cloudera.com, reviews@impala.incubator.apache.org CC: Henry Robinson , Matthew Jacobs , Dan Hecht , Bharath Vissapragada , Marcel Kornacker Reply-To: dtsirogiannis@cloudera.com X-Gerrit-MessageType: comment Subject: =?UTF-8?Q?=5BImpala-ASF-CR=5D_IMPALA-4041=3A_Limit_catalog_and_admission_control_updates_to_coordinators=0A?= X-Gerrit-Change-Id: I5f2c74abdbcd60ac050efa323616bd41182ceff3 X-Gerrit-ChangeURL: X-Gerrit-Commit: 63d080c1f1843ff31984ea4a0c2fa00e7b3d81ac In-Reply-To: References: MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Content-Disposition: inline User-Agent: Gerrit/2.12.7 archived-at: Fri, 24 Mar 2017 21:27:25 -0000 Dimitris Tsirogiannis has posted comments on this change. Change subject: IMPALA-4041: Limit catalog and admission control updates to coordinators ...................................................................... Patch Set 4: (10 comments) I am not so sure about removing the catalog and in-flight queries handles. They provide a way of visually validating that worker nodes do not receive catalog updates and that they don't schedule queries. http://gerrit.cloudera.org:8080/#/c/6344/4/be/src/scheduling/scheduler.cc File be/src/scheduling/scheduler.cc: Line 259 > This line is effectively removed, right? It was added in: https://gerrit.cl After inspecting the code and also talking to Lars, I believe this removal is safe. This change has the following effect. The scheduler has to wait for the statestore update that includes the local backend in order to add it to the backend config. Before that, the backend_config could be empty and scheduling should fail unless exec_at_coord is true. We have tests for these cases. http://gerrit.cloudera.org:8080/#/c/6344/4/be/src/service/impala-server.cc File be/src/service/impala-server.cc: Line 1588: LOG(WARNING) << "Failed to convert hostname " << hostname << " to IP address"; > log status? Done PS4, Line 1601: address > nit: descriptor Done PS4, Line 1604: } : if (status.ok()) { > else { Done PS4, Line 1909: NULL > nullptr Done PS4, Line 1931: NULL > nullptr Done http://gerrit.cloudera.org:8080/#/c/6344/4/be/src/service/impala-server.h File be/src/service/impala-server.h: Line 436: // it to the list of known backends and tell the statestore by adding it to > this function isn't telling the statestore anything, it's only adding to to Done PS4, Line 438: In > nit: should be To, not In Done http://gerrit.cloudera.org:8080/#/c/6344/4/bin/start-impala-cluster.py File bin/start-impala-cluster.py: PS4, Line 40: 3 > is there any way to make this default == the value of '-s'? If I run -s1 ri Hm, not sure how to do that. I removed the check. http://gerrit.cloudera.org:8080/#/c/6344/4/tests/custom_cluster/test_coordinators.py File tests/custom_cluster/test_coordinators.py: Line 83: client2.close() > can you add a check that the worker has not received the catalog metadata? Done -- To view, visit http://gerrit.cloudera.org:8080/6344 To unsubscribe, visit http://gerrit.cloudera.org:8080/settings Gerrit-MessageType: comment Gerrit-Change-Id: I5f2c74abdbcd60ac050efa323616bd41182ceff3 Gerrit-PatchSet: 4 Gerrit-Project: Impala-ASF Gerrit-Branch: master Gerrit-Owner: Dimitris Tsirogiannis Gerrit-Reviewer: Bharath Vissapragada Gerrit-Reviewer: Dan Hecht Gerrit-Reviewer: Dimitris Tsirogiannis Gerrit-Reviewer: Henry Robinson Gerrit-Reviewer: Marcel Kornacker Gerrit-Reviewer: Matthew Jacobs Gerrit-HasComments: Yes