You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by yidan zhao <hi...@gmail.com> on 2022/03/17 02:38:01 UTC

如何得知当前Flink集群的leader

如题，集群resourceManager等角色的leader，以及具体每个任务的leader从UI能否得知。
目前从ZK获取是一种方法，但不好看，需要程序解码。

Re: 如何得知当前Flink集群的leader

Posted by yidan zhao <hi...@gmail.com>.
额。好吧。我其实是问下有没有UI等简单方法看。看日志的话我还是更偏向看zk信息更快点。

yu'an huang <h....@gmail.com> 于2022年3月22日周二 01:13写道：

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

Re: 如何得知当前Flink集群的leader

Posted by yu'an huang <h....@gmail.com>.
你好，你可以通过日志中" {ip:port}  was granted leadership with …" 知道当前leader的地址，通过对比IP地址和端口号就可以确认哪一个进程是active的JM。希望可以帮到你。

> On 18 Mar 2022, at 2:06 PM, yidan zhao <hi...@gmail.com> wrote:
> 
> 看报错的时候不知道看哪个JM进程的日志。以及想重启JM的时候，需要确认当前JM重启是否会影响集群（非leader重启不影响，leader重启就会导致任务都fail
> over）。
> 
> yu'an huang <h....@gmail.com> 于2022年3月18日周五 00:05写道：
> 
>> 请问什么场景下你需要获得RM等的leader呢？从Flink UI可以查看日志，从日志中也能看到现在的leader，不知道是否满足你的使用场景。
>> 
>> 
>>> On 17 Mar 2022, at 10:38 AM, yidan zhao <hi...@gmail.com> wrote:
>>> 
>>> 如题，集群resourceManager等角色的leader，以及具体每个任务的leader从UI能否得知。
>>> 目前从ZK获取是一种方法，但不好看，需要程序解码。
>> 
>>

Re: 如何得知当前Flink集群的leader

Posted by yidan zhao <hi...@gmail.com>.
看报错的时候不知道看哪个JM进程的日志。以及想重启JM的时候，需要确认当前JM重启是否会影响集群（非leader重启不影响，leader重启就会导致任务都fail
over）。

yu'an huang <h....@gmail.com> 于2022年3月18日周五 00:05写道：

> 请问什么场景下你需要获得RM等的leader呢？从Flink UI可以查看日志，从日志中也能看到现在的leader，不知道是否满足你的使用场景。
>
>
> > On 17 Mar 2022, at 10:38 AM, yidan zhao <hi...@gmail.com> wrote:
> >
> > 如题，集群resourceManager等角色的leader，以及具体每个任务的leader从UI能否得知。
> > 目前从ZK获取是一种方法，但不好看，需要程序解码。
>
>

Re: 如何得知当前Flink集群的leader

Posted by yu'an huang <h....@gmail.com>.
请问什么场景下你需要获得RM等的leader呢？从Flink UI可以查看日志，从日志中也能看到现在的leader，不知道是否满足你的使用场景。


> On 17 Mar 2022, at 10:38 AM, yidan zhao <hi...@gmail.com> wrote:
> 
> 如题，集群resourceManager等角色的leader，以及具体每个任务的leader从UI能否得知。
> 目前从ZK获取是一种方法，但不好看，需要程序解码。