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 陈佳豪 <ja...@yeah.net> on 2022/11/24 10:18:56 UTC

如何能正确的获取任务总写入量?

大佬们好 
背景:
业务端想基于flink metrics获取到任务总写入量。正常情况下通过指numRecordsIn指标是可以获取到增长的写入量的,如果用户自己误操作删了目标表并且重新建表恢复了,这个时候上报的numRecordsIn指标就会是0这就导致无法准确的获取任务写入总量了。不知道各位大佬有没有碰到这种情况希望能得到一个解决方案! 感谢。

回复:如何能正确的获取任务总写入量?

Posted by JasonLee <17...@163.com>.
hi


你可以把之前的历史值保存下来,比如保存在状态里面或者第三方存储,任务重启后在加上之前的值。


Best
JasonLee


---- 回复的原邮件 ----
| 发件人 | 陈佳豪<ja...@yeah.net> |
| 发送日期 | 2022年11月24日 18:18 |
| 收件人 | <us...@flink.apache.org> |
| 主题 | 如何能正确的获取任务总写入量? |
大佬们好
背景:
业务端想基于flink metrics获取到任务总写入量。正常情况下通过指numRecordsIn指标是可以获取到增长的写入量的,如果用户自己误操作删了目标表并且重新建表恢复了,这个时候上报的numRecordsIn指标就会是0这就导致无法准确的获取任务写入总量了。不知道各位大佬有没有碰到这种情况希望能得到一个解决方案! 感谢。