退订
On Thu, Jun 15, 2023 at 7:23 PM im huzi wrote:
> 退订
>
> On Tue, Jun 13, 2023 at 08:51 casel.chen wrote:
>
> > 线上跑了200多个flink
> >
> sql作业,接了prometheus指标(prometheus定期来获取作业指标)监控后没跑一会儿就将prometheus内存打爆(开了64GB内存),查了一下是因为指标名称过长导致的。
> > flink
> >
>
退订
On Tue, Jun 13, 2023 at 08:51 casel.chen wrote:
> 线上跑了200多个flink
> sql作业,接了prometheus指标(prometheus定期来获取作业指标)监控后没跑一会儿就将prometheus内存打爆(开了64GB内存),查了一下是因为指标名称过长导致的。
> flink
> sql作业的指标名称一般是作业名称+算子名称组成的,而算子名称是由sql内容拼出来的,在select字段比较多或sql较复杂的情况下容易生成过长的名称,
> 请问这个问题有什么好的办法解决吗?
配置参数之后, task name 也会简化.
Best,
Feng
On Wed, Jun 14, 2023 at 11:23 AM casel.chen wrote:
>
>
>
>
>
>
>
>
>
>
>
>
> 谢谢,除了operator name,我看了flink sql作业生成的task name也很长,目前有办法可以简化下吗?例如
>
>
>
谢谢,除了operator name,我看了flink sql作业生成的task name也很长,目前有办法可以简化下吗?例如
hi casel
1. 可以考虑使用 Flink1.15, 使用精简的 operator name
https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/config/#table-exec-simplify-operator-name-enabled
2. Flink 也提供了 restful 接口直接获取瞬时的 metric,如果不需要历史的 metric
线上跑了200多个flink
sql作业,接了prometheus指标(prometheus定期来获取作业指标)监控后没跑一会儿就将prometheus内存打爆(开了64GB内存),查了一下是因为指标名称过长导致的。
flink
sql作业的指标名称一般是作业名称+算子名称组成的,而算子名称是由sql内容拼出来的,在select字段比较多或sql较复杂的情况下容易生成过长的名称,
请问这个问题有什么好的办法解决吗?