Hi,大佬们

如何在任务结束后获取Accumulator 数据?
参考代码:(但是无法获取)
ableResult execute = statementSet.execute();
Optional<JobClient> jobClient = execute.getJobClient();
jobClient.get().getAccumulators().get()

PS: 最初的需求是: 对任务同步的数据量做统计。希望在批任务结束后,准确的获取Accumulator 中值,但是在K8S 中无法获取?

大佬求助!!先磕为敬

回复