当flink作业完成时,flink如何计算“jobid”并存储在jobarchive中?

qxsslcnc  于 2021-06-24  发布在  Flink
关注(0)|答案(1)|浏览(653)

在flink中,作业被分配作业id,如 73ca9d2c10693ff8fd002738a7fc538a . 有关于如何计算作业id的指针吗?

k3fezbri

k3fezbri1#

flink作业ID是随机生成的数字。看到了吗 JobID.java 以及 AbstractID.java 详情。

/**
     * Constructs a new random ID from a uniform distribution.
     */
    public AbstractID() {
        this.lowerPart = RND.nextLong();
        this.upperPart = RND.nextLong();
    }

相关问题