Re: Using Queryable State within 1 job + docs suggestion

Posted by Annemarie Burger on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Using-Queryable-State-within-1-job-docs-suggestion-tp35227p35321.html

Hi,

So what I meant was that I have a keyed stream, and from each
thread/keygroup/PU I want to query the state of the other
threads/keygroups/PUs.

Does anybody have any experience with this?

I'm currently working on it, and the main problem seems to be that the
Queryable State Client requires the JobID from which to query the state,
which in my case would be the same as its own jobID. Any ideas how to
workaround this?
Using env.getStreamGraph.getJobGraph.getJobID doesn't seem to work.

Best,
Annemarie



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/