From user-return-17478-archive-asf-public=cust-asf.ponee.io@flink.apache.org Fri Jan 5 18:47:42 2018 Return-Path: X-Original-To: archive-asf-public@eu.ponee.io Delivered-To: archive-asf-public@eu.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by mx-eu-01.ponee.io (Postfix) with ESMTP id B44F3180647 for ; Fri, 5 Jan 2018 18:47:42 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id A438B160C27; Fri, 5 Jan 2018 17:47:42 +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 C3D10160C15 for ; Fri, 5 Jan 2018 18:47:41 +0100 (CET) Received: (qmail 25938 invoked by uid 500); 5 Jan 2018 17:47:40 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Delivered-To: mailing list user@flink.apache.org Received: (qmail 25929 invoked by uid 99); 5 Jan 2018 17:47:40 -0000 Received: from mail-relay.apache.org (HELO mail-relay.apache.org) (140.211.11.15) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 05 Jan 2018 17:47:40 +0000 Received: from mail-qt0-f181.google.com (mail-qt0-f181.google.com [209.85.216.181]) by mail-relay.apache.org (ASF Mail Server at mail-relay.apache.org) with ESMTPSA id 2E8E71A008C for ; Fri, 5 Jan 2018 17:47:40 +0000 (UTC) Received: by mail-qt0-f181.google.com with SMTP id g10so6600937qtj.12 for ; Fri, 05 Jan 2018 09:47:40 -0800 (PST) X-Gm-Message-State: AKwxyte9MgnV6AfJjYAE41TL7gLbx4kSLVzAsSyRbG1Ojojf1i6taU9d o+MGjthbzviOXoZ3m0tAIzh8zWC08pe0IyEOvzc= X-Google-Smtp-Source: ACJfBou3uhMlCbHafgDe2lW6kVGTSeT7BzniuyGXjkta1fKkYzy/23aEj4tMWt4enD6IOreuDSCyzIjYC2N/1HX+7bU= X-Received: by 10.237.60.238 with SMTP id e43mr5390336qtf.49.1515174457571; Fri, 05 Jan 2018 09:47:37 -0800 (PST) MIME-Version: 1.0 Received: by 10.12.172.228 with HTTP; Fri, 5 Jan 2018 09:46:57 -0800 (PST) In-Reply-To: <695A805C-8C7D-4722-AE9E-DBCE5BC4DA45@lightbend.com> References: <3AF502C0-B75A-4258-842C-26B81A44F854@lightbend.com> <695A805C-8C7D-4722-AE9E-DBCE5BC4DA45@lightbend.com> From: Till Rohrmann Date: Fri, 5 Jan 2018 18:46:57 +0100 X-Gmail-Original-Message-ID: Message-ID: Subject: Re: Queryable State in Flink 1.4 To: Boris Lublinsky Cc: user Content-Type: multipart/alternative; boundary="001a113bc94a51027305620b0b48" --001a113bc94a51027305620b0b48 Content-Type: text/plain; charset="UTF-8" Did you add the `flink-queryable-state-runtime` jar as a dependency to your project? You can check the log whether a queryable state proxy and server have been started. Cheers, Till On Fri, Jan 5, 2018 at 5:19 PM, Boris Lublinsky < boris.lublinsky@lightbend.com> wrote: > I also tried to comment out > > // config.setInteger(ConfigConstants.LOCAL_NUMBER_TASK_MANAGER, 2); > > Still no luck. > Do you guys have a working example for queryable state for 1.4 somewhere? > > Boris Lublinsky > FDP Architect > boris.lublinsky@lightbend.com > https://www.lightbend.com/ > > On Jan 5, 2018, at 6:33 AM, Till Rohrmann wrote: > > Hi Boris, > > if you start 2 TaskManagers on the same host, then you have to define a > port range for the KvState server and the proxy. Otherwise the Flink > cluster should not be able to start. > > Cheers, > Till > > On Thu, Jan 4, 2018 at 11:19 PM, Boris Lublinsky < > boris.lublinsky@lightbend.com> wrote: > >> It appears, that queryable state access significantly changed in 1.4 >> compared to 1.3. >> >> Documentation on the queryable state client https://ci.apache.org/p >> rojects/flink/flink-docs-release-1.4/dev/stream/state/querya >> ble_state.html#example >> States that the client needs to connect to a proxy port. >> My implementation, which I used for 1.3 is enclosed >> >> >> Here I am setting both server port and proxy port. >> When I am running it on a localhost and try to do lsof -i:9069 and lsof >> -i:9067 It does not show anything using this port. >> >> Am I missing something? >> >> As a result my query implementation >> >> >> Return an error - connection refused >> >> My state is defined in the following class >> >> >> Boris Lublinsky >> FDP Architect >> boris.lublinsky@lightbend.com >> https://www.lightbend.com/ >> >> >> > > --001a113bc94a51027305620b0b48 Content-Type: text/html; charset="UTF-8" Content-Transfer-Encoding: quoted-printable
Did you add the `flink-queryable-state-runtime` jar as a d= ependency to your project? You can check the log whether a queryable state = proxy and server have been started.

Cheers,
Ti= ll

On = Fri, Jan 5, 2018 at 5:19 PM, Boris Lublinsky <boris.lublinsky= @lightbend.com> wrote:
I also tried to comment out=C2=A0
//    config.set=
Integer(ConfigConstants.LOCAL_NUMBER_TASK_MANAGER, 2);
=
Still no luck.
Do you guys have a working exampl= e for queryable state for 1.4 somewhere?


On Jan 5, 2= 018, at 6:33 AM, Till Rohrmann <trohrmann@apache.org> wrote:

=
Hi Boris,

if you start 2 TaskManag= ers on the same host, then you have to define a port range for the KvState = server and the proxy. Otherwise the Flink cluster should not be able to sta= rt.

Cheers,
Till

On Thu, Jan 4, 2018 at 11:1= 9 PM, Boris Lublinsky <boris.lublinsky@lightbend.com&= gt; wrote:
It appears, that queryable state access significantly cha= nged in 1.4 compared to 1.3.

Documentation on the query= able state client=C2=A0https://ci.apache.org/projects/flink/flink-docs-release-= 1.4/dev/stream/state/queryable_state.html#example
States that = the client needs to connect to a proxy port.
My implementation, w= hich I used for 1.3 is enclosed=C2=A0


Here I am setting both server port and proxy po= rt.
When I am running it on a localhost and try to do=C2=A0lsof -i:9069 and=C2=A0lsof -i:9067 It does not show anythi= ng using this port.

Am I missing something?
As a result my query= =C2=A0implementation=C2=A0

=C2=A0=C2=A0
<= span style=3D"font-size:11px">Return an error - connection refused

=
My state is defined in the following = class=C2=A0





--001a113bc94a51027305620b0b48--