You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by deng <bn...@139.com> on 2019/05/13 00:44:17 UTC
回复: flink 无法 获取从数据源读了多少条数据，写入目标数据源多少条数据
源算子是没有接收统计的，只有发送统计，sink算子刚好相反。
发件人： jszhouchong@163.com
发送时间： 2019-05-10 17:28
收件人： user-zh@flink.apache.org
主题： flink 无法 获取从数据源读了多少条数据，写入目标数据源多少条数据
大家好，
我现在有一个程序消费kafka，写入kafka，我想获取flink 消费了多少条kafka数据，写入了多少条kafka数据，，但是在flink页面上 第一个subtasks的Records received是0，最后一个subtask的Records send也是0，但是第一个subtask的Records send是正确的，最后一个subtask的Records received也是正确的。也就是我现在我不能从flink的metric中获取到flink程序从kafka中读了多少条数据，flink程序写入kafka多少条数据。
请问一下，我如何能从flink metric中得到从kafka消费了多少数据和写入kafka多少数据
非常感谢各位老师