You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by 谭家良 <ta...@126.com> on 2022/05/12 05:47:50 UTC

回复： Flink Application + HA与HistoryServer的使用问题

thanks，Yang.
Btw, 恭喜晋升apache flink的PMC！


Best，
tanjialiang.
在2022年5月12日 10:32，Yang Wang<da...@gmail.com> 写道：
可以临时通过-D "$internal.pipeline.job-id=xxxx"来自定义job id，但是个内部参数

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

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

Best,
Yang

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



我使用的Application模式：Kubernetes
我使用的HA模式：Kubernetes HA


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