开发者社区> 问答> 正文

自定义metrics reporter 如何不通过flink conf来注册并生效

Hi all,

请问实现了 MetricReporter, CharacterFilter,Scheduled, Reporter 的自定义 customerReporter 如何能在 代码env里面注册并实现metric上报,要求不在flink conf.xml 文件里面配置 该customerReporter的信息?

需求:在自定义的source 和sink等算子里面计算处理成功,失败的数据条数并通过自定义reporter上报,并且该reporter需要是通用型的即 适用于多个flink 任务从而避开重复造轮子。

thx*来自志愿者整理的flink邮件归档

展开
收起
小阿怪 2021-12-07 10:10:07 908 0
1 条回答
写回答
取消 提交回答
  • 问题1 找到了https://issues.apache.org/jira/browse/FLINK-12336,且已经合并到master分支了,看issues中修复版本是1.12.0 问题2 我又在Flink1.11.1下详细测试了,flink-metrics-influxdb-1.11.0.jar在plugins/influxdb和plugins/metrics-influx均可以上报mertics,当然我也尝试过目录plugins/metrics-influx123也是可以上报来自志愿者整理的flink邮件归档 Hi Fisher 尝试理解一下你的需求,你自己实现了一个 report,也希望在 source 和 sink 中计算一些 metric,希望把 source 和 sink 的这些 metric 通过自定义的 report 上报到你指定的地方。然后不希望在 env 里面配置 report 的信息,是这样吗? 能否解释下为什么不希望在 flink-conf 中进行配置,而是希望在 env 中进行配置吗来自志愿者整理的flink邮件归档

    2021-12-07 11:40:25
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载