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-archive.2336050.n4.nabble.com/Fwd-Not-able-to-query-Queryable-State-tp8808p8937.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
