tison 你好，
我netstat查看了想要指定的节点的端口情况，8082没有被占用。所以有点困惑这个报错。
在 2019-11-27 10:59:52，"tison" <[email protected]> 写道：
>8082 端口被占用了吧？
>
>Best,
>tison.
>
>
>杨浩程 <[email protected]> 于2019年11月27日周三 上午10:56写道：
>
>> 各位大佬好！
>> 请教各位个问题：使用的flink 版本1.9.0。测试flink on yarn 指定节点 开启yarn session 会话。
>> 希望yarnsession开启的集群 jobmanager开启在我指定的节点上。
>> 更改的配置如下：
>> 报错信息如下：
>>
>> ===============================================================================================================
>> 2019-11-27 10:35:45,640 INFO
>> org.apache.flink.shaded.curator.org.apache.curator.framework.imps.CuratorFrameworkImpl
>> - backgroundOperati
>> 2019-11-27 10:35:45,650 INFO
>> org.apache.flink.shaded.zookeeper.org.apache.zookeeper.ZooKeeper -
>> Session: 0x36ea133e2b51435 closed
>> 2019-11-27 10:35:45,650 INFO
>> org.apache.flink.shaded.zookeeper.org.apache.zookeeper.ClientCnxn -
>> EventThread shut down for session: 0x3
>> 2019-11-27 10:35:45,651 INFO
>> org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping
>> Akka RPC service.
>> 2019-11-27 10:35:45,659 INFO
>> org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping
>> Akka RPC service.
>> 2019-11-27 10:35:45,666 INFO
>> akka.remote.RemoteActorRefProvider$RemotingTerminator - Shutting
>> down remote daemon.
>> 2019-11-27 10:35:45,669 INFO
>> akka.remote.RemoteActorRefProvider$RemotingTerminator - Remote
>> daemon shut down; proceeding with fl
>> 2019-11-27 10:35:45,676 INFO
>> akka.remote.RemoteActorRefProvider$RemotingTerminator - Shutting
>> down remote daemon.
>> 2019-11-27 10:35:45,677 INFO
>> akka.remote.RemoteActorRefProvider$RemotingTerminator - Remote
>> daemon shut down; proceeding with fl
>> 2019-11-27 10:35:45,696 INFO
>> akka.remote.RemoteActorRefProvider$RemotingTerminator - Remoting
>> shut down.
>> 2019-11-27 10:35:45,696 INFO
>> akka.remote.RemoteActorRefProvider$RemotingTerminator - Remoting
>> shut down.
>> 2019-11-27 10:35:45,709 INFO
>> org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped
>> Akka RPC service.
>> 2019-11-27 10:35:45,713 INFO
>> org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped
>> Akka RPC service.
>> 2019-11-27 10:35:45,714 ERROR
>> org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Could not
>> start cluster entrypoint YarnSess
>> org.apache.flink.runtime.entrypoint.ClusterEntrypointException: Failed to
>> initialize the cluster entrypoint YarnSessionClusterEntrypoint.
>> at
>> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startCluster(ClusterEntrypoint.java:182)
>> at
>> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runClusterEntrypoint(ClusterEntrypoint.java:501)
>> at
>> org.apache.flink.yarn.entrypoint.YarnSessionClusterEntrypoint.main(YarnSessionClusterEntrypoint.java:93)
>> Caused by: org.apache.flink.util.FlinkException: Could not create the
>> DispatcherResourceManagerComponent.
>> at
>> org.apache.flink.runtime.entrypoint.component.AbstractDispatcherResourceManagerComponentFactory.create(AbstractDispatcherResou
>> at
>> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runCluster(ClusterEntrypoint.java:210)
>> at
>> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.lambda$startCluster$0(ClusterEntrypoint.java:164)
>> at java.security.AccessController.doPrivileged(Native Method)
>> at javax.security.auth.Subject.doAs(Subject.java:422)
>> at
>> org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1875)
>> at
>> org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41)
>> at
>> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startCluster(ClusterEntrypoint.java:163)
>> ... 2 more
>> Caused by: java.net.BindException: Could not start rest endpoint on any
>> port in port range 8082
>> at
>> org.apache.flink.runtime.rest.RestServerEndpoint.start(RestServerEndpoint.java:219)
>> at
>> org.apache.flink.runtime.entrypoint.component.AbstractDispatcherResourceManagerComponentFactory.create(AbstractDispatcherResou
>> ... 9 more
>>
>> End of LogType:jobmanager.log
>>
>> ===============================================================================================================
>> 请问这种问题要怎么解决？多谢各位大佬！
>>
>>
>>
>>
