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
jobmanager. Maybe turning on DEBUG logging helps already?
Regards,
Robert
On Thu, Sep 8, 2016 at 8:08 AM, Pushpendra Jaiswal <
pushpendra.jaiswa...@gmail.com> wrote:
> 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
>
