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/
