Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io 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 D8783160C15 for ; Wed, 3 Jan 2018 07:25:09 +0100 (CET) Received: (qmail 78204 invoked by uid 500); 3 Jan 2018 06:25:08 -0000 Mailing-List: contact dev-help@kafka.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@kafka.apache.org Delivered-To: mailing list dev@kafka.apache.org Received: (qmail 78192 invoked by uid 99); 3 Jan 2018 06:25:08 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd2-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 03 Jan 2018 06:25:08 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd2-us-west.apache.org (ASF Mail Server at spamd2-us-west.apache.org) with ESMTP id 878C11A0452 for ; Wed, 3 Jan 2018 06:25:07 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -0.021 X-Spam-Level: X-Spam-Status: No, score=-0.021 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd2-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=confluent-io.20150623.gappssmtp.com Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new, port 10024) with ESMTP id 5cInPNGOMU9S for ; Wed, 3 Jan 2018 06:25:05 +0000 (UTC) Received: from mail-it0-f49.google.com (mail-it0-f49.google.com [209.85.214.49]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTPS id 6D0A95F666 for ; Wed, 3 Jan 2018 06:25:04 +0000 (UTC) Received: by mail-it0-f49.google.com with SMTP id m11so13127263iti.1 for ; Tue, 02 Jan 2018 22:25:04 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=confluent-io.20150623.gappssmtp.com; s=20150623; h=subject:to:references:from:organization:message-id:date:user-agent :mime-version:in-reply-to; bh=aPnoSMX0+OtI8J0trlUiq/r6kdOtV3vNC9Giix5sjxM=; b=qS/r4XK3dnrzEAnTVsKB3SFwUouDsiY+5OK7En7Me8iI/kFitYuBnis58/hReW9lUG Bm65oLpDzuS1o5IyoQ+EYWIrzem+KWFocGZckbk9p99MSyH+F2zmGyix7q4BZP2sdmvE X3Gd7riGgBB9xLIIz9FrJ3qe/NlamcgEz14TicRxAzY0d1Nb9V1WMyIG/zMdV360JJHG N+6J64e1eSuNbzU1Ssh61IfCah0DAL5GnmNYh2LIVAU+TClFmaVk/NxPllM3RjcYxib3 jrkecURjMry+ytDbP5Ijw4vJVuXMgp72C/Rxpsw7gzI9nzBlp2SEiuJuYhtPeIq3UC7m WEtw== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:subject:to:references:from:organization :message-id:date:user-agent:mime-version:in-reply-to; bh=aPnoSMX0+OtI8J0trlUiq/r6kdOtV3vNC9Giix5sjxM=; b=KP1e4R1Eo6Fm3844sF7EQCCy//uLlN8mBnkMQAXwldiRqV3DX0SFjQAQ/wO7FEKpQo RG93roBvb1RtW3n2NBKmO4P3kia1zrMm1f02/D4H3jNQM0vhyWWikbiCoT0wLZYIGtos vMRewFmmoY3IeNgSuVZPh0/Rgk/MjYjCYf6z7OUwdI7ZDnIW4i4uecB/Q9Yq4vn2Xk0k h3X12uRnKVckmRNYpkrmDD3roNdYb6coQ9X8KGGf2y5hwILVzowZxcazXgQtMdFOVB4Q xyLw2T6f64OZ/9/1AISrjWwNvbD9XeuZXArrX8m52rBpbbWH3Dlg79B6mqYPrtAo6zNt N+Dg== X-Gm-Message-State: AKGB3mIlpGSEIIfv/IW/EwPXAimBB88Mlmr4mgIqSPddjuN9B24NIqmK kSWb0RXM8QwOTmm/9BequD3Rq1TwmlE= X-Google-Smtp-Source: ACJfBotVrjrE86zeg+uSdFRH4eGjPbnCXsK1CeBismvH3I/O2z9g4rJBkt4BwfqGaQdMFYhoZ9vLFw== X-Received: by 10.36.189.205 with SMTP id x196mr679282ite.152.1514960702676; Tue, 02 Jan 2018 22:25:02 -0800 (PST) Received: from Matthias-Sax-Macbook-Pro.local ([2601:647:4a03:2600:9181:9a0c:a78b:f2a]) by smtp.gmail.com with ESMTPSA id d3sm292809itf.39.2018.01.02.22.25.01 for (version=TLS1_2 cipher=ECDHE-RSA-AES128-GCM-SHA256 bits=128/128); Tue, 02 Jan 2018 22:25:01 -0800 (PST) Subject: Re: [VOTE] KIP-239 Add queryableStoreName() to GlobalKTable To: dev@kafka.apache.org References: From: "Matthias J. Sax" Organization: Confluent Inc Message-ID: <086aad8d-2f45-fe6b-b377-75c5c0f5a97b@confluent.io> Date: Tue, 2 Jan 2018 22:24:59 -0800 User-Agent: Mozilla/5.0 (Macintosh; Intel Mac OS X 10.13; rv:52.0) Gecko/20100101 Thunderbird/52.5.2 MIME-Version: 1.0 In-Reply-To: Content-Type: multipart/signed; micalg=pgp-sha512; protocol="application/pgp-signature"; boundary="Uf1xESPyAXA5l6BhSIFXzzgB6TXMcJ4pI" archived-at: Wed, 03 Jan 2018 06:25:10 -0000 --Uf1xESPyAXA5l6BhSIFXzzgB6TXMcJ4pI Content-Type: multipart/mixed; boundary="6mejx2xn3VmiBmjCXsfKd6aDX5BaEtOZT"; protected-headers="v1" From: "Matthias J. Sax" To: dev@kafka.apache.org Message-ID: <086aad8d-2f45-fe6b-b377-75c5c0f5a97b@confluent.io> Subject: Re: [VOTE] KIP-239 Add queryableStoreName() to GlobalKTable References: In-Reply-To: --6mejx2xn3VmiBmjCXsfKd6aDX5BaEtOZT Content-Type: text/plain; charset=utf-8 Content-Language: en-US Content-Transfer-Encoding: quoted-printable @Richard: you can close this vote thread with a summary as usual and update the KIP wiki page accordingly. -Matthias On 1/2/18 9:57 PM, Richard Yu wrote: > A subsequent PR has already been created: > https://github.com/apache/kafka/pull/4340/ > It should be seen on the JIRA. >=20 >=20 >=20 > On Tue, Jan 2, 2018 at 9:51 PM, Ewen Cheslack-Postava > wrote: >=20 >> Oh, the KIP passes w/ the required votes. My comment was just on >> implementation details. I will leave comments about that up to the >> subsequent PR and to the Kafka Streams folks that are much better suit= ed >> than me to comment on them :) >> >> -Ewen >> >> On Tue, Jan 2, 2018 at 9:28 PM, Richard Yu >> wrote: >> >>> After investigation, I have found that the >>> InternalStreamsBuilder#globalTable method is the only instance where = the >>> constructor for GlobalKTableImpl is called. >>> The KTableValueGetterSupplier parameter used in this particular >> constructor >>> is an instance of KTableSourceValueGetterSupplier. Hence, your >> requirement >>> is satisfied. >>> >>> Since this is the vote thread, if you have further comments, please >> comment >>> on the pull request. >>> >>> On Tue, Jan 2, 2018 at 6:38 PM, Ewen Cheslack-Postava >> >>> wrote: >>> >>>> +1 binding >>>> >>>> The idea seems reasonable. Looking at it implementation-wise, seems >> there >>>> is a bit of awkwardness because GlobalKTableImpl uses a >>>> KTableValueGetterSupplier which seems to possibly have multiple stor= es, >>> but >>>> maybe using the more specific KTableSourceValueGetterSupplier >>>> implementation instead can resolve that. >>>> >>>> -Ewen >>>> >>>> On Mon, Jan 1, 2018 at 6:22 PM, Ted Yu wrote: >>>> >>>>> Gentle reminder: one more binding vote is needed for the KIP to pas= s. >>>>> >>>>> Cheers >>>>> >>>>> On Thu, Dec 21, 2017 at 4:13 AM, Damian Guy >>>> wrote: >>>>> >>>>>> +1 >>>>>> >>>>>> On Wed, 20 Dec 2017 at 21:09 Ted Yu wrote: >>>>>> >>>>>>> Ping for more (binding) votes. >>>>>>> >>>>>>> The pull request is ready. >>>>>>> >>>>>>> On Fri, Dec 15, 2017 at 12:57 PM, Guozhang Wang < >>> wangguoz@gmail.com> >>>>>>> wrote: >>>>>>> >>>>>>>> +1 (binding), thanks! >>>>>>>> >>>>>>>> On Fri, Dec 15, 2017 at 11:56 AM, Ted Yu >>>>> wrote: >>>>>>>> >>>>>>>>> Hi, >>>>>>>>> Here is the discussion thread: >>>>>>>>> >>>>>>>>> http://search-hadoop.com/m/Kafka/uyzND12QnH514pPO9?subj=3D >>>>>>>>> Re+DISCUSS+KIP+239+Add+queryableStoreName+to+GlobalKTable >>>>>>>>> >>>>>>>>> Please vote on this KIP. >>>>>>>>> >>>>>>>>> Thanks >>>>>>>>> >>>>>>>> >>>>>>>> >>>>>>>> >>>>>>>> -- >>>>>>>> -- Guozhang >>>>>>>> >>>>>>> >>>>>> >>>>> >>>> >>> >> >=20 --6mejx2xn3VmiBmjCXsfKd6aDX5BaEtOZT-- --Uf1xESPyAXA5l6BhSIFXzzgB6TXMcJ4pI Content-Type: application/pgp-signature; name="signature.asc" Content-Description: OpenPGP digital signature Content-Disposition: attachment; filename="signature.asc" -----BEGIN PGP SIGNATURE----- Comment: GPGTools - https://gpgtools.org iQJKBAEBCgA0FiEEFpAnjJ4fbvgzKNUmjQjbao0qTDYFAlpMdzwWHG1hdHRoaWFz QGNvbmZsdWVudC5pbwAKCRCNCNtqjSpMNj2+D/9vWljsXdBmGnNTonyzHL0469g1 KjI7LRXtLxnHLtuXR/tuvM+qgxFr9A672T1SzJkWq5vQBrwMjwTMfdx6IvQKfVS/ vkqsF3gAIEcexbZ0J2TxSQAe6J8gNcVhYA8W8y2+/bGGkE+WO3XlXaEjACWSphWt qViWFwL4n7Yl9U529+81IVckuA/7fzIBXhqF77OljJaNNfWZrlee40Yg078gVZhI E1cA6V0ZLm62Ix53qjqZdiQUPtxa3nYuFrmf+P3JzF+FpyzH4AIOY/2m5t0mVEVb YUTWCyNNbTV8JwTCu7G4Ijk45mljASxb11FQakl+I4FEjAeGhLdDgu1wowH8xXih xlBMKenkzk5soEsaGBctN3WVWM0XRWHM7LBqSHCozu7m9GI0K/rjP4GJ3B5sfhh4 kWSxtBFkokSRtuHj2yYbrFoRH98wtCLwZbyOn/uVPmcv92bDIfWTTPDDZT7kA22H 1Rqx/VOYNIYxm8QIOdRDY1rd53Ihesd655rW5fy7WQohzGx1fFrTzkaElMDOzb5I ZBRSMiSZhubbz2HH5NggO1tlymzhMtBmxFwMsGIsMlyTdDCeNzQhTJQ9eLIyb8Dl 2tLrf1WA3tiU2wXmGps+AM7s3UkegtwopFCqJ9MdoY2/PUI8hdUoodwlBMAlEIey cf7/aybhyFIX2cmUVw== =UMnR -----END PGP SIGNATURE----- --Uf1xESPyAXA5l6BhSIFXzzgB6TXMcJ4pI--