Hi, 按照你的描述,我猜测你使用的是 Application 模式吧?这种模式下 user code 会在 JobManager 侧执行,Job 执行结束后会直接 shutdown cluster。
可以尝试使用 session mode[1] 部署 cluster [1] https://nightlies.apache.org/flink/flink-docs-master/docs/deployment/resource-providers/native_kubernetes/#session-mode Best, Weihua On Mon, Mar 6, 2023 at 8:54 PM wangwei <gavin_wangl...@163.com> wrote: > > Hi,大佬们 > > 如何在任务结束后获取Accumulator 数据? > 参考代码:(但是无法获取) > ableResult execute = statementSet.execute(); > Optional<JobClient> jobClient = execute.getJobClient(); > jobClient.get().getAccumulators().get() > > PS: 最初的需求是: 对任务同步的数据量做统计。希望在批任务结束后,准确的获取Accumulator 中值,但是在K8S 中无法获取? > > 大佬求助!!先磕为敬 >