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 CB053200CA4 for ; Wed, 24 May 2017 02:11:25 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id C9C56160BD3; Wed, 24 May 2017 00:11: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 1D661160BC3 for ; Wed, 24 May 2017 02:11:24 +0200 (CEST) Received: (qmail 98841 invoked by uid 500); 24 May 2017 00:11: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 98830 invoked by uid 99); 24 May 2017 00:11:24 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 24 May 2017 00:11:24 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd4-us-west.apache.org (ASF Mail Server at spamd4-us-west.apache.org) with ESMTP id A8802C0FD6 for ; Wed, 24 May 2017 00:11:23 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-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 (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id QeJtT7KupY1a for ; Wed, 24 May 2017 00:11:21 +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 489345F20C for ; Wed, 24 May 2017 00:11:21 +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 v4O0BKA7017435; Wed, 24 May 2017 00:11:20 GMT Message-Id: <201705240011.v4O0BKA7017435@ip-10-146-233-104.ec2.internal> Date: Wed, 24 May 2017 00:11:20 +0000 From: "Henry Robinson (Code Review)" To: Marcel Kornacker , impala-cr@cloudera.com, reviews@impala.incubator.apache.org Reply-To: henry@cloudera.com X-Gerrit-MessageType: comment Subject: =?UTF-8?Q?=5BImpala-ASF-CR=5D_IMPALA-4890/5143=3A_Coordinator_race_involving_TearDown=28=29=0A?= X-Gerrit-Change-Id: I457a6424a0255c137336c4bc01a6e7ed830d18c7 X-Gerrit-ChangeURL: X-Gerrit-Commit: 10c08fdf897db5a242d61d2f535589399d802211 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: Wed, 24 May 2017 00:11:26 -0000 Henry Robinson has posted comments on this change. Change subject: IMPALA-4890/5143: Coordinator race involving TearDown() ...................................................................... Patch Set 1: (1 comment) Patch looks pretty reasonable, will finish shortly. http://gerrit.cloudera.org:8080/#/c/6897/1/be/src/runtime/coordinator.cc File be/src/runtime/coordinator.cc: Line 895 > i think the waitforbackendcompletion call should be removed altogether, but I believe that PlanRootSink() may set eos in GetNext() at the same time as it returns the final rows, if the sender calls Send() immediately followed by FlushFinal() before the consumer gets woken up in GetNext(). It looks to me like the callers expect that this might be possible. But since the PRS puts those results into a QueryResultSet owned by the ClientRequestState, I think it's safe to tear down the PRS once it sets eos. As regards post-query finalization - what about computing the final profiles based on the last report sent by each fragment? Do we need to wait before calling Coordinator::ComputeQuerySummary()? I think we should aim to be rid of WaitForBackendCompletion() here, but maybe it still needs to exist in some form on a tear-down path which is not on the user's critical path. -- To view, visit http://gerrit.cloudera.org:8080/6897 To unsubscribe, visit http://gerrit.cloudera.org:8080/settings Gerrit-MessageType: comment Gerrit-Change-Id: I457a6424a0255c137336c4bc01a6e7ed830d18c7 Gerrit-PatchSet: 1 Gerrit-Project: Impala-ASF Gerrit-Branch: master Gerrit-Owner: Marcel Kornacker Gerrit-Reviewer: Henry Robinson Gerrit-Reviewer: Marcel Kornacker Gerrit-HasComments: Yes