可以临时通过-D "$internal.pipeline.job-id=xxxx"来自定义job id,但是个内部参数

你可以看下[1],了解更多讨论的信息

[1]. https://issues.apache.org/jira/browse/FLINK-19358

Best,
Yang

谭家良 <tanjl_w...@126.com> 于2022年5月11日周三 22:17写道:

>
>
> 我使用的Application模式:Kubernetes
> 我使用的HA模式:Kubernetes HA
>
>
> 目前Application + HA发现所有的Job ID都变成了“000000000000”,但是在HistoryServer中,他会使用Job
> ID作为归档文件的文件名。那么如果这样,HistoryServer应该怎么与Application + HA相结合呢?
>
>

回复