大家好:
我按照官网的文档,调试了flink metrics 的 reporter
,加载了Slf4jReporter,这个Reporter运行是正常了,但是发现了个问题,
在taskManager中打印里面的信息的时候,打印出来的是:
ambari.taskmanager.container_e31_1557826320302_0005_01_02.Status.JVM.ClassLoader.ClassesLoaded:
12044
这里的格式范围,我看了源码应该是.taskmanager..:
但是这里就存在了个问题了,这里的host,显示的是ambari
: Wednesday, May 15, 2019 20:24
To: user-zh@flink.apache.org
Subject: flink metrics的 Reporter 问题
大家好:
我按照官网的文档,调试了flink metrics 的 reporter
,加载了Slf4jReporter,这个Reporter运行是正常了,但是发现了个问题,
在taskManager中打印里面的信息的时候,打印出来的是:
ambari.taskmanager.container_e31_1557826320302_0005_01_02
; [3] https://issues.apache.org/jira/browse/FLINK-12520
>
> From: 戴嘉诚
> Sent: Wednesday, May 15, 2019 20:24
> To: user-zh@flink.apache.org
> Subject: flink metrics的 Reporter 问题
>
> 大家好:
> 我按照官网的文档,调试了flink metrics 的 reporter
Hi 唐云
我用的是flink1.8
感谢你的解答,我刚刚也找到了源码里面的[2]方式截取方式。目前来说,应该只能自己在report中,调用系统变量来获取主机名称了。
发件人: Yun Tang
发送时间: 2019年5月15日 21:11
收件人: user-zh@flink.apache.org
主题: Re: flink metrics的 Reporter 问题
Hi 嘉诚
不清楚你使用的Flink具体版本,不过这个显示host-name第一部分的逻辑是一直存在的,因为大部分场景下host-name只需要取第一部分即可表征。具体实现代码可以参阅
[1] 和 [2
好的,感谢
发件人: Xintong Song
发送时间: 2019年5月15日 21:17
收件人: user-zh@flink.apache.org
主题: Re: flink metrics的 Reporter 问题
取hostname的第一部分是为了和hdfs的用法保持一致,可以参考一下当时的issue,作者专门提到了为什么要这么做。
https://issues.apache.org/jira/browse/FLINK-1170?focusedCommentId=14175285&