如何增加Flink中SinkFunction的numRecordsOutPut指标？

作者: 独奏♪
发布时间: 2024-01-24 09:00:36 (3月前)
转自：

2 条回复

0#
回复此人
你抱着孩子@先跑 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> numRecordsIn和numRecordsOut指标仅计算在Flink作业本身内流动的流记录，并且不包括与外部系统的通信。换句话说，消息来源不会报告任何记录，并且接收器不会报告任何记录。 </p> <P> 在我看来，你有几个选择： </p> <OL> <LI> 使用接收器上的numRecordsIn指标作为您想要知道的近似值 </LI> <LI> 分叉或扩展RedisSink并添加所需的指标 </LI> </醇> <P> 将显示添加计数器度量标准的模式 <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.7/monitoring/metrics.html#counter" rel="nofollow noreferrer"> 这里 </A> 。 </p> <P> 对于redis接收器，您可以在open（）方法中初始化Counter，并在invoke（）中递增它。但这似乎毫无意义，因为这只会反映numRecordsIn指标。如果您的redis接收器正在执行缓冲批量写入，那么等待递增指标直到数据实际发送到redis可能更有意义 - 在这种情况下，您可能更倾向于使用Meter而不是Counter。 </p> </DIV>

编辑

登录后才能参与评论