hi

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


Best
JasonLee


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

回复