Re: 请问同一个flink history server能够支持多个flink application cluster吗?
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] >
Re: 请问同一个flink history server能够支持多个flink application cluster吗?
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]
请问同一个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]