I've just uploaded a Flink-1.7.2 compatible version of the original code at [1]. However FoldingStateDescriptor is now deprecated and should be migrated to AggregatingStateDescriptor (according to the javadoc). Is there any guide about how to do this? I've drafted it in [2] but I didn't know the right way to continue the migration..
Any suggestions? [1] https://github.com/okkam-it/flink-examples/blob/master/src/main/java/com/dataartisans/queryablestatedemo/EventCountJobLegacy.java [2] https://github.com/okkam-it/flink-examples/blob/master/src/main/java/com/dataartisans/queryablestatedemo/EventCountJobNew.java On Tue, Mar 5, 2019 at 1:11 PM Fabian Hueske <fhue...@gmail.com> wrote: > 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 >>> >>>
