Get/Set Job Id in Flink 1.11

[Li Wang]

Hi team,

We're running flink jobs in application mode. Pre Flink 1.7, the job id by default is `00000000000000000000000000000000`. 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

[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.sh --job-id <jobid>" to start the application

cluster with fixed job id.

Best,

Yang

Li Wang <[hidden email]> 于2021年2月4日周四 上午10:12写道：

Hi team,

We're running flink jobs in application mode. Pre Flink 1.7, the job id by default is `00000000000000000000000000000000`. 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