On querying to Queryable State it throws Exception, Exception org.apache.flink.runtime.query.UnknownKvStateLocation: No KvStateLocation found for KvState instance with name 'queryStore'. at org.apache.flink.runtime.jobmanager.JobManager.org$apache$flink$runtime$jobmanager$JobManager$$handleKvStateMessage(JobManager.scala:1460)
Code def reduceToQueryable = { stream.asQueryableState("queryStore", reducingStateDesc) } [image: JobGraph] <http://i.stack.imgur.com/Mr1tv.png> Is there any other way to register Queryable state. I am fetching jobID through rest call to App master http://localhost:8081/jobs/ { "jobs-running": [ "b5b1bf3646e39ebc17d97a3b8ba23b5d" ], "jobs-finished": [], "jobs-cancelled": [], "jobs-failed": [] } Is this jid is the same as required by KvStateFunction