Re: Get/Set Job Id in Flink 1.11

2021-02-03 Thread Yang Wang
Hi Wang Li, The application mode is introduced in release 1.10 and has replaced the old StandaloneJobClusterEntrypoint. By default, if you enable the HA, then you will get a ZERO_JOB_ID. Otherwise, it will be a random uuid. For standalone application mode, you could use the "./bin/standalone-job.

Get/Set Job Id in Flink 1.11

2021-02-03 Thread Li Wang
Hi team, We're running flink jobs in application mode. Pre Flink 1.7, the job id by default is ``. However, in Flink 1.11, we found the job id is random. Is there a way to set job id or we can only retrieve the job id by ourselves each time? Thanks. - Li