Re: Queryable State Client with 1.3.0-rc0

Sorry for yet another update but this is the complete settings for making it work on Flink 1.3: Configuration configuration = new Configuration(); configuration.setInteger(ConfigConstants.TASK_MANAGER_NUM_TASK_SLOTS, 8); configuration.setString(JobManagerOptions.ADDRESS, "localhost"); configurat

Re: Queryable State Client with 1.3.0-rc0

Hi Claudio, Quick question: what exactly was your call for getting the local environment with web UI? Did you also have a custom Configuration where you specified, for example, that the queryable state server should be enabled? I can make an example work where I start a local cluster in one pro

Re: Queryable State Client with 1.3.0-rc0

Hi Claudio, Quick follow up: querying a locally started cluster does not work out-of-box anymore in Flink 1.3. You can manually start a mini cluster that has the required settings, though. You would do something like this: Configuration configuration = new Configuration(); configuration.addAll(

Re: Queryable State Client with 1.3.0-rc0

Hi Claudio, The documentation for this was recently updated: https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/stream/queryable_state.html#querying-state . Could you see if