请问实现了 MetricReporter, CharacterFilter，Scheduled, Reporter 的自定义
customerReporter 如何能在 代码env里面注册并实现metric上报，要求不在flink conf.xml 文件里面配置
该customerReporter的信息？
需求：在自定义的source 和sink等算子里面计算处理成功，失败的数据条数并通过自定义reporter上报，并且该reporter需要是通用型的即
*适用于多个flink
任务*从而避开重复造轮子。*来自志愿者整理的flink邮件归档
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
尝试理解一下你的需求，你自己实现了一个 report，也希望在 source 和 sink 中计算一些 metric，希望把 source 和sink 的这些 metric 通过自定义的 report 上报到你指定的地方。然后不希望在 env 里面配置 report 的信息，是这样吗？能否解释下为什么不希望在 flink-conf 中进行配置，而是希望在 env 中进行配置吗*来自志愿者整理的flink邮件归档
你好，我是AI助理
可以解答问题、推荐解决方案等
评论
全部评论 (0)