flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Flavio Pompermaier <pomperma...@okkam.it>
Subject Re: EventCountJob for Flink 1.7.2
Date Tue, 05 Mar 2019 10:22:56 GMT
I discovered that now (in Flink 1.7.2( queryable state server is enabed if
queryable state client is found on the classpath, i.e.:

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-queryable-state-client-java_${scala.version}</artifactId>
<version>${flink.version}</version>
<scope>provided</scope>
</dependency>

I hope this could help someone else..

On Mon, Mar 4, 2019 at 6:54 PM Flavio Pompermaier <pompermaier@okkam.it>
wrote:

> Hi to all,
> I was trying to test the EventCountJob[1] on Flink 1.7.2 but there's no
> more QueryableStateOptions.SERVER_ENABLE. How can I specify to enable query
> server on LocalFlinkMiniCluster?
> I've tried to chenage it to
> config.setString(QueryableStateOptions.SERVER_PORT_RANGE, "9067");
> but it is ignored.
>
> [1]
> https://github.com/dataArtisans/flink-queryable_state_demo/blob/master/src/main/java/com/dataartisans/queryablestatedemo/EventCountJob.java
>
> Best,
> Flavio
>
>

Mime
View raw message