I looked at the code, and StreamExecutionEnvironment#getStreamGraph#getJobGraph#getJobID is generating a random ID unrelated to the actual ID used.
Is there any way to fetch the real ID at runtime? Use case: fetch most recent checkpoint from stable storage for automated restarts. Most recent checkpoint has form ".../checkpoints/flink_app_id/chk-123" On Thu, Nov 21, 2019 at 11:28 AM Lei Nie <lyzj...@gmail.com> wrote: > > This does not get the correct id: > StreamExecutionEnvironment#getStreamGraph#getJobGraph#getJobID = > eea5abc21dd8743a4090f4a3a660f9e8 > Actual job ID (from webUI): 1357d21be640b6a3b8a86a063f4bba8a > > > > On Thu, Nov 7, 2019 at 6:56 PM vino yang <yanghua1...@gmail.com> wrote: > > > > Hi Lei Nie, > > > > You can use > > `StreamExecutionEnvironment#getStreamGraph#getJobGraph#getJobID` to get the > > job id. > > > > Best, > > Vino > > > > Lei Nie <lyzj...@gmail.com> 于2019年11月8日周五 上午8:38写道： > >> > >> Hello, > >> I am currently executing streaming jobs via StreamExecutionEnvironment. Is > >> it possible to retrieve the Flink job ID/YARN ID within the context of a > >> job? I'd like to be able to automatically register the job such that > >> monitoring jobs can run (REST api requires for example job id). > >> > >> Thanks
