从apache beam重命名flink runner metrics

1mrurvl1  于 2021-07-15  发布在  Flink
关注(0)|答案(0)|浏览(176)

最近,我在apachebeam作业中添加了一些简单的度量,并检查了生成的度量(在flink控制台和prometheus中)。
但是,当添加一个度量 Metrics.counter("sampleNs", "sampleMetric"); ,结果输出为 flink_taskmanager_job_task_operator_sampleNs_sampleMetric .
是否有现成的支持删除前缀并保留导出的度量 sampleNs_sampleMetric (或任何其他更简单的前缀)?
唯一相关的问题,这件事接近解决这个问题是以下邮件列表线程,但似乎没有简单的解决办法http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/renaming-the-metrics-td36124.html.
如果我想从ApacheBeam获得类似的东西。。。它是否需要分叉我自己的flink,这样我就可以在本地分叉中覆盖apache beam中使用的flink?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题