JobManager使用zk做高可用的时候，如何得到当前活跃的JobManager地址

[cuicle <cu...@163.com>]

当我创建一个StreamExecutionEnvironment的时候，需要指定JobManager的地址
StreamExecutionEnvironment.createRemoteEnvironment("localhost", 8080);
当使用zk做高可用的时候，如何获得当前活跃的JobManager地址？



--
Sent from: http://apache-flink.147419.n8.nabble.com/

Re: JobManager使用zk做高可用的时候，如何得到当前活跃的JobManager地址

[Yang Wang <da...@gmail.com>]

你可以参考一下RestClusterClient里面实现的使用ClientHighAvailabilityServices来获取leader地址的实现


Best,
Yang

yidan zhao <hi...@gmail.com> 于2021年6月15日周二 下午2:52写道：

> 代码里不需要remoteEnv创建，你这种removeEnv是通过本地ide提交任务的情况。这种情况很少见，一般线上网络环境和办公网络是隔离的吧。
>
> yidan zhao <hi...@gmail.com> 于2021年6月15日周二 下午2:49写道：
> >
> > 你这个方式不是用于测试嘛。线上情况不应该使用flink run命令嘛。使用flink run的情况下本身就是基于zk自动获取jm地址提交的。
> >
> > cuicle <cu...@163.com> 于2021年6月15日周二 下午2:04写道：
> > >
> > > 别估计啊。。。理论上只有一个active
> > > jobManager，其它的都是standby。就算你说的可以，那客户端再维护所有的JobManager的地址也是很丑的呀。
> > >
> > >
> > > 我是想是否能从zk里面直接获取当前的active jobManager
> > >
> > >
> > >
> > > --
> > > Sent from: http://apache-flink.147419.n8.nabble.com/
>

Re: JobManager使用zk做高可用的时候，如何得到当前活跃的JobManager地址

[cuicle <cu...@163.com>]

我们的业务需求就是要在代码里面动态远程提交job



--
Sent from: http://apache-flink.147419.n8.nabble.com/

Re: JobManager使用zk做高可用的时候，如何得到当前活跃的JobManager地址

[yidan zhao <hi...@gmail.com>]

代码里不需要remoteEnv创建，你这种removeEnv是通过本地ide提交任务的情况。这种情况很少见，一般线上网络环境和办公网络是隔离的吧。

yidan zhao <hi...@gmail.com> 于2021年6月15日周二 下午2:49写道：
>
> 你这个方式不是用于测试嘛。线上情况不应该使用flink run命令嘛。使用flink run的情况下本身就是基于zk自动获取jm地址提交的。
>
> cuicle <cu...@163.com> 于2021年6月15日周二 下午2:04写道：
> >
> > 别估计啊。。。理论上只有一个active
> > jobManager，其它的都是standby。就算你说的可以，那客户端再维护所有的JobManager的地址也是很丑的呀。
> >
> >
> > 我是想是否能从zk里面直接获取当前的active jobManager
> >
> >
> >
> > --
> > Sent from: http://apache-flink.147419.n8.nabble.com/

Re: JobManager使用zk做高可用的时候，如何得到当前活跃的JobManager地址

[yidan zhao <hi...@gmail.com>]

你这个方式不是用于测试嘛。线上情况不应该使用flink run命令嘛。使用flink run的情况下本身就是基于zk自动获取jm地址提交的。

cuicle <cu...@163.com> 于2021年6月15日周二 下午2:04写道：
>
> 别估计啊。。。理论上只有一个active
> jobManager，其它的都是standby。就算你说的可以，那客户端再维护所有的JobManager的地址也是很丑的呀。
>
>
> 我是想是否能从zk里面直接获取当前的active jobManager
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/

Re: JobManager使用zk做高可用的时候，如何得到当前活跃的JobManager地址

[cuicle <cu...@163.com>]

别估计啊。。。理论上只有一个active
jobManager，其它的都是standby。就算你说的可以，那客户端再维护所有的JobManager的地址也是很丑的呀。


我是想是否能从zk里面直接获取当前的active jobManager



--
Sent from: http://apache-flink.147419.n8.nabble.com/

Re: JobManager使用zk做高可用的时候，如何得到当前活跃的JobManager地址

[yidan zhao <hi...@gmail.com>]

指定随意一个都可以估计。

cuicle <cu...@163.com> 于2021年6月15日周二 上午11:34写道：
>
> 当我创建一个StreamExecutionEnvironment的时候，需要指定JobManager的地址
> StreamExecutionEnvironment.createRemoteEnvironment("localhost", 8080);
> 当使用zk做高可用的时候，如何获得当前活跃的JobManager地址？
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/