Re: Not able to query : Queryable State

I think the exception message is saying what’s the problem. The job simply does not exist. You can verify that by running bin/flink list or look it up in the web interface. The reason is that calling env.getStreamGraph.getJobGraph will generate a new JobGraph (not the one which is sent to the JobM

Re: Not able to query : Queryable State

Hi Stefan Please find below stack trace and code : java.lang.IllegalStateException: Job 81ca41b13e7be8feb99f064e5a9a4237 not found at org.apache.flink.runtime.jobmanager.JobManager.org$apache$flink$runtime$jobmanager$JobManager$$handleKvStateMessage(JobManager.scala:1470) at org.a

Re: Not able to query : Queryable State

Hi Vishnu /val env = StreamExecutionEnvironment.getExecutionEnvironment val jobID = env.getStreamGraph.getJobGraph.getJobID/ As I am using the jobId of current running job. It should exist. Thanks and regards Pushpendra -- View this message in context: http://apache-flink-user-mailing-list-

Re: Not able to query : Queryable State

Hi, Are you sure the job id matches with running job? The error clearly says JobID not found. How are you setting the JobID, If I remember correctly, I used something like val jobId = JobID.fromHexString("myjob_id_here") to get the JobID object and used it to call client.getKvState() Thanks, Vis

Re: Not able to query : Queryable State

Hi, can you provide some more code from your job and a full stack trace for your problem? That would help us to figure out the reason. Best, Stefan > Am 31.08.2016 um 13:00 schrieb Pushpendra Jaiswal > : > > > -- Forwarded message -- > From: Pushpendra Jaiswal