Unable to find KvState flink Queryablestate

[pushpendra.jaiswal]

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)
}

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

[rmetzger0]

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 <[hidden email]> 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)
}

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