Hi Chenyu,
這確實是目前尚未解決的一個問題,相關的 jira issue 可以看這 [1]。
jira issue 底下的討論串有提到一個替代方案是:使用 -D\$internal.pipeline.job-id=$(cat
/proc/sys/kernel/random/uuid|tr -d "-") 主動為 application 模式的任務產生隨機的 jobid。
但由於此配置參數屬於 flink 內部參數,可能不保證未來任何改動後的向後兼容性,請謹慎考慮後再使用。
[1] https://issues.apache.org/jira/browse/FLINK-19358
Chenyu Zheng 於 2021年8月20日 週五 下午12:16寫道:
> History Server的API也是使用jobid作为区分
>
> * /config
> * /jobs/overview
> * /jobs/
> * /jobs//vertices
> * /jobs//config
> * /jobs//exceptions
> * /jobs//accumulators
> * /jobs//vertices/
> * /jobs//vertices//subtasktimes
> * /jobs//vertices//taskmanagers
> * /jobs//vertices//accumulators
> * /jobs//vertices//subtasks/accumulators
> * /jobs//vertices//subtasks/
> *
> /jobs//vertices//subtasks//attempts/
> *
>
> /jobs//vertices//subtasks//attempts//accumulators
> * /jobs//plan
>
>
> From: Chenyu Zheng
> Reply-To: "user-zh@flink.apache.org"
> Date: Friday, August 20, 2021 at 11:43 AM
> To: "user-zh@flink.apache.org"
> Subject: 请问同一个flink history server能够支持多个flink application cluster吗?
>
> 您好,
>
> 我们目前在k8s上以flink application模式运行作业,现在希望部署一个history
> server方便debug。但是根据文档,flink
> historyserver貌似只支持单个cluster下不同job的使用方法,如果存在多个cluster,相同的jobID将会出现错误。
>
> 请问对于多个application cluster,history使用的最佳姿势是什么样的?
>
> 谢谢[cid:image001.png@01D795B8.6430A670]
>