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

[Fisher Xiang <fi...@gmail.com>]

Hi all,

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

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

thx

BR
Fisher

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

[Congxian Qiu <qc...@gmail.com>]

Hi  Fisher
   尝试理解一下你的需求，你自己实现了一个 report，也希望在 source 和 sink 中计算一些 metric，希望把 source 和
sink 的这些 metric 通过自定义的 report 上报到你指定的地方。然后不希望在 env 里面配置 report 的信息，是这样吗？
能否解释下为什么不希望在 flink-conf 中进行配置，而是希望在 env 中进行配置吗

Best,
Congxian


Fisher Xiang <fi...@gmail.com> 于2020年7月23日周四 下午10:16写道：

> Hi all,
>
> 请问实现了 MetricReporter, CharacterFilter，Scheduled, Reporter 的自定义
> customerReporter 如何*能在 代码env里面注册并实现metric上报*，要求不在flink conf.xml 文件里面配置
> 该customerReporter的信息？
>
> 需求：在自定义的source 和sink等算子里面计算处理成功，失败的数据条数并通过自定义reporter上报，并且该reporter需要是通用型的即
> *适用于多个flink
> 任务*从而避开重复造轮子。
>
> thx
>
> BR
> Fisher
>