我在flink任务中添加了metric,并定时通过日志的方式输出。
现在发现在flink任务由于异常原因重启后,监控指标从0开始重新统计了。
针对自己实现的算子,我在metric中添加了部分信息,可以将多次指标进行合并。
但针对使用到的连接器中的指标,好像没法这么弄。大家有什么好的方案么?

回复