您好，目前ML不支持图片，能将配置贴上来么？ 另外看报错信息像是8082端口被占用导致rest服务起不起来
Best, Yangze Guo On Wed, Nov 27, 2019 at 10:56 AM 杨浩程 <yhc_mylio...@163.com> wrote: > 各位大佬好！ > 请教各位个问题：使用的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 > > =============================================================================================================== > 请问这种问题要怎么解决？多谢各位大佬！ > > > >
