Thanks Flavio!

Am Di., 5. März 2019 um 11:23 Uhr schrieb Flavio Pompermaier <
pomperma...@okkam.it>:

> 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
>>
>>

Reply via email to