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

2020-07-25 文章 Congxian Qiu
Hi Fisher 尝试理解一下你的需求,你自己实现了一个 report,也希望在 source 和 sink 中计算一些 metric,希望把 source 和 sink 的这些 metric 通过自定义的 report 上报到你指定的地方。然后不希望在 env 里面配置 report 的信息,是这样吗? 能否解释下为什么不希望在 flink-conf 中进行配置,而是希望在 env 中进行配置吗 Best, Congxian Fisher Xiang 于2020年7月23日周四 下午10:16写道: > Hi all, > > 请问实现了

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

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