flink on K8S(operator) 如何获取 Accumulator

Hi,大佬们 如何在任务结束后获取Accumulator 数据？ 参考代码：（但是无法获取） ableResult execute = statementSet.execute(); Optional jobClient = execute.getJobClient(); jobClient.get().getAccumulators().get() PS: 最初的需求是： 对任务同步的数据量做统计。希望在批任务结束后，准确的获取Accumulator 中值，但是在K8S 中无法获取？ 大佬求助！！先磕为敬

退订

退订