你好,你可以通过日志中" {ip:port} was granted leadership with …" 知道当前leader的地址,通过对比IP地址和端口号就可以确认哪一个进程是active的JM。希望可以帮到你。
> On 18 Mar 2022, at 2:06 PM, yidan zhao <hinobl...@gmail.com> wrote: > > 看报错的时候不知道看哪个JM进程的日志。以及想重启JM的时候,需要确认当前JM重启是否会影响集群(非leader重启不影响,leader重启就会导致任务都fail > over)。 > > yu'an huang <h.yuan...@gmail.com> 于2022年3月18日周五 00:05写道: > >> 请问什么场景下你需要获得RM等的leader呢?从Flink UI可以查看日志,从日志中也能看到现在的leader,不知道是否满足你的使用场景。 >> >> >>> On 17 Mar 2022, at 10:38 AM, yidan zhao <hinobl...@gmail.com> wrote: >>> >>> 如题,集群resourceManager等角色的leader,以及具体每个任务的leader从UI能否得知。 >>> 目前从ZK获取是一种方法,但不好看,需要程序解码。 >> >>