flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Robert Metzger <rmetz...@apache.org>
Subject Re: Unable to find KvState flink Queryablestate
Date Fri, 09 Sep 2016 09:57:40 GMT
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.jaiswal90@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
>

Mime
View raw message