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 <pomperma...@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
>
>
