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

2022-05-11 文章 谭家良
thanks,Yang. Btw, 恭喜晋升apache flink的PMC! Best, tanjialiang. 在2022年5月12日 10:32,Yang Wang 写道: 可以临时通过-D "$internal.pipeline.job-id="来自定义job id,但是个内部参数 你可以看下[1],了解更多讨论的信息 [1]. https://issues.apache.org/jira/browse/FLINK-19358 Best, Yang 谭家良 于2022年5月11日周三 22:17写道:

Re: Flink Application + HA与HistoryServer的使用问题

2022-05-11 文章 Yang Wang
可以临时通过-D "$internal.pipeline.job-id="来自定义job id,但是个内部参数 你可以看下[1],了解更多讨论的信息 [1]. https://issues.apache.org/jira/browse/FLINK-19358 Best, Yang 谭家良 于2022年5月11日周三 22:17写道: > > > 我使用的Application模式:Kubernetes > 我使用的HA模式:Kubernetes HA > > > 目前Application + HA发现所有的Job

Flink Application + HA与HistoryServer的使用问题

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