在你指定的ha路径的子目录(yarn的话会有层applicationid目录) get下这个节点 leader/rest_server_lock 试试。
原始邮件 发件人: yidan zhao<hinobl...@gmail.com> 收件人: user-zh<user-zh@flink.apache.org> 发送时间: 2021年6月15日(周二) 14:50 主题: Re: JobManager使用zk做高可用的时候，如何得到当前活跃的JobManager地址 代码里不需要remoteEnv创建，你这种removeEnv是通过本地ide提交任务的情况。这种情况很少见，一般线上网络环境和办公网络是隔离的吧。 yidan zhao <hinobl...@gmail.com<mailto:hinobl...@gmail.com>> 于2021年6月15日周二 下午2:49写道： > > 你这个方式不是用于测试嘛。线上情况不应该使用flink run命令嘛。使用flink run的情况下本身就是基于zk自动获取jm地址提交的。 > > cuicle <cui...@163.com<mailto:cui...@163.com>> 于2021年6月15日周二 下午2:04写道： > > > > 别估计啊。。。理论上只有一个active > > jobManager，其它的都是standby。就算你说的可以，那客户端再维护所有的JobManager的地址也是很丑的呀。 > > > > > > 我是想是否能从zk里面直接获取当前的active jobManager > > > > > > > > -- > > Sent from: http://apache-flink.147419.n8.nabble.com/
