最近,我在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?
暂无答案!
目前还没有任何答案,快来回答吧!