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