Hi,
I fear that you have to look into the Flink code to understand what's going
on. Queryable state is an experimental, undocumented feature, and the
committer who mainly implemented it (Ufuk) is currently on vacation.
There's probably some problem with the registration of the state at the
jobman
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$$handleKvS