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 69B0C200B5A for ; Thu, 4 Aug 2016 14:22:26 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 68353160AAB; Thu, 4 Aug 2016 12:22:26 +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 86307160A7C for ; Thu, 4 Aug 2016 14:22:25 +0200 (CEST) Received: (qmail 44964 invoked by uid 500); 4 Aug 2016 12:22:24 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@flink.apache.org Delivered-To: mailing list user@flink.apache.org Received: (qmail 44954 invoked by uid 99); 4 Aug 2016 12:22: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; Thu, 04 Aug 2016 12:22:24 +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 30D48CD2D2 for ; Thu, 4 Aug 2016 12:22:24 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 2.742 X-Spam-Level: ** X-Spam-Status: No, score=2.742 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, FREEMAIL_ENVFROM_END_DIGIT=0.25, HTML_MESSAGE=2, RCVD_IN_DNSWL_LOW=-0.7, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, SPF_PASS=-0.001, URI_HEX=1.313] autolearn=disabled Authentication-Results: spamd1-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id H-Hkim1B9H2N for ; Thu, 4 Aug 2016 12:22:22 +0000 (UTC) Received: from mail-ua0-f182.google.com (mail-ua0-f182.google.com [209.85.217.182]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTPS id 7726360E6D for ; Thu, 4 Aug 2016 12:22:21 +0000 (UTC) Received: by mail-ua0-f182.google.com with SMTP id 35so173264995uap.1 for ; Thu, 04 Aug 2016 05:22:21 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:in-reply-to:references:from:date:message-id:subject:to; bh=rmksklwAB6tJN6bGEh+rTA6jFwgX4a7hPvxqE2zo0gw=; b=KDqtBoXBmpmHKGrmbw4GuV6TbbeCBhnXtJylnbrKDlhZYtw6Pw+tqsvfbD5AbvvePx KQ58yLdz/+HDNEWt3LnG0+ovpNVQSymEtILiGMOD3+Y0UQWUE0ZvAVo0JJPpBuaXJ4t+ avGAoEN1LE6/BrLLHil1v1Ol12X3QqLgO5kLVoh1VXSQuQV2pzlOjPbDXlemb3WzsxDM ymddb1bpMCsVPUhFl1Xt1lk7SS7DVnDGm/qldAvvhj59EnJsTuIBhPc3Q8K9F4qwdB2w oDtEEC04H/cjjYIPK4MLP/mVsH8urup9hCmdi7s5/FkjVXwk2QAS83LFvg8VkCzCzF0l OtHg== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20130820; h=x-gm-message-state:mime-version:in-reply-to:references:from:date :message-id:subject:to; bh=rmksklwAB6tJN6bGEh+rTA6jFwgX4a7hPvxqE2zo0gw=; b=MPVl1DAlQ2O8ny/uenjOUmlTLw6vSTom/QEgqnCS516q1h1U6q3I8li6Ehzxsjh9u2 FTR2GqYqo2rgr4mwRlMKO9MNyvgKRSMSCvSmKM/cTdlVEm7ouWcmXGBUj7flou63MSKc hVES/3X9UGdGDtsb9KBbFPh7i8y+juNNKarbftBzOZPw70BfRZXVmPPcharoLrluajSW us37+NrXh4++TfT09Wlz2M/PAMFz1O8HL2wmzLmTBVIvYB17LKQEMEfvDrxWQV4p0vaF QRTm/TXCSYWqSrxbllzGbnYvttKyKtg6Nrp/Ylxa3vlQis2UFaGowgdxfPq5oB/Yt0av bysg== X-Gm-Message-State: AEkoouur/kZ6tibQImTvTHqVDHDY9tBxhqhBVnP4q2eK1wIknsLKASG+Grg7tNeM/iKtmb+rVCa5zTQq8A0mTg== X-Received: by 10.176.69.142 with SMTP id u14mr4048474uau.13.1470313340155; Thu, 04 Aug 2016 05:22:20 -0700 (PDT) MIME-Version: 1.0 Received: by 10.159.40.73 with HTTP; Thu, 4 Aug 2016 05:21:59 -0700 (PDT) In-Reply-To: References: <1470304387700-8324.post@n4.nabble.com> From: Vishnu Viswanath Date: Thu, 4 Aug 2016 08:21:59 -0400 Message-ID: Subject: Re: Regarding QueryableState To: user@flink.apache.org Content-Type: multipart/alternative; boundary=94eb2c11b964593c9605393e00cb archived-at: Thu, 04 Aug 2016 12:22:26 -0000 --94eb2c11b964593c9605393e00cb Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: quoted-printable Hi Ufuk, I was able to create a QueryableState stream and query it when running in cluster mode in my local machine, but I am unable to Query the stream when running on AWS cluster, getting error AbstractMethodError at kvState.getSerializedValue(serializedKeyAndNamespace) in KvStateServerHandler.java while querying. Not sure if I am doing something wrong here, so eagerly waiting for the merge, to try it again :) Thanks, Vishnu On Thu, Aug 4, 2016 at 7:40 AM, Ufuk Celebi wrote: > You can expect it to be merged by the end of this week. > > Note that the APIs are very low level at the moment though. In the PR > branch you can have a look at the QueryableStateITCase for more > details. > > =E2=80=93 Ufuk > > > On Thu, Aug 4, 2016 at 11:53 AM, vinay patil > wrote: > > Hi All, > > > > For one use case I want to make use of this feature instead of querying > > external store like Cassandra or ES. > > > > Can you please let me know if this is under development or present in t= he > > master branch. > > > > It will be of great help if you can provide examples or link to the > > documentation. > > > > Thanks, > > Vinay Patil > > > > > > > > -- > > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Regar= ding-QueryableState-tp8324.html > > Sent from the Apache Flink User Mailing List archive. mailing list > archive at Nabble.com. > --94eb2c11b964593c9605393e00cb Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable
Hi Ufuk,

I was able to create a Queryab= leState stream and query it when running in cluster mode in my local machin= e, but I am unable to Query the stream when running on AWS cluster, getting= error AbstractMethodError at kvState.getSerializedValue(serializedKeyAndNa= mespace) in KvStateServerHandler.java while querying.

<= div>Not sure if I am doing something wrong here, so eagerly waiting for the= merge, to try it again :)

T= hanks,
Vishnu

On Thu, Aug 4, 2016 at 7:40 AM, Ufuk Cele= bi <uce@apache.org> wrote:
Yo= u can expect it to be merged by the end of this week.

Note that the APIs are very low level at the moment though. In the PR
branch you can have a look at the QueryableStateITCase for more
details.

=E2=80=93 Ufuk


On Thu, Aug 4, 2016 at 11:53 AM, vinay patil <vinay18.patil@gmail.com> wrote:
> Hi All,
>
> For one use case I want to make use of this feature instead of queryin= g
> external store like Cassandra or ES.
>
> Can you please let me know if this is under development or present in = the
> master branch.
>
> It will be of great help if you can provide examples or link to the > documentation.
>
> Thanks,
> Vinay Patil
>
>
>
> --
> View this message in context: http://apache-flink-user-mailing-lis= t-archive.2336050.n4.nabble.com/Regarding-QueryableState-tp8324.html > Sent from the Apache Flink User Mailing List archive. mailing list arc= hive at Nabble.com.

--94eb2c11b964593c9605393e00cb--