Hi 像上面提到的,jobClient.get().getAccumulators()会从flink集群获取作业相关信息,如果是application模式,作业结束后flink集群也会退出。你可以通过其他方式,包括session集群运行或者启动history server等方式,也可以通过自定义metrics等输出到其他系统
Best, Shammon On Tue, Mar 7, 2023 at 11:27 PM 李银苗 <ftpl...@126.com> wrote: > 退订
Hi 像上面提到的,jobClient.get().getAccumulators()会从flink集群获取作业相关信息,如果是application模式,作业结束后flink集群也会退出。你可以通过其他方式,包括session集群运行或者启动history server等方式,也可以通过自定义metrics等输出到其他系统
Best, Shammon On Tue, Mar 7, 2023 at 11:27 PM 李银苗 <ftpl...@126.com> wrote: > 退订