大佬好!
flink ./start-cluster.sh 启动过程中如下错误,但是该端口号未占用啊,请大佬帮看看。谢谢
org.apache.flink.runtime.entrypoint.ClusterEntrypointException: Failed to
initialize the cluster entrypoint StandaloneSessionClusterEntrypoint.
at
org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startCluster(ClusterEntrypoint.java:212)
~[flink-dist_2.11-1.13.3.jar:1.13.3]
at
org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runClusterEntrypoint(ClusterEntrypoint.java:600)
[flink-dist_2.11-1.13.3.jar:1.13.3]
at
org.apache.flink.runtime.entrypoint.StandaloneSessionClusterEntrypoint.main(StandaloneSessionClusterEntrypoint.java:59)
[flink-dist_2.11-1.13.3.jar:1.13.3]
Caused by: org.apache.flink.util.FlinkException: Could not create the
DispatcherResourceManagerComponent.
at
org.apache.flink.runtime.entrypoint.component.DefaultDispatcherResourceManagerComponentFactory.create(DefaultDispatcherResourceManagerComponentFactory.java:275)
~[flink-dist_2.11-1.13.3.jar:1.13.3]
at
org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runCluster(ClusterEntrypoint.java:250)
~[flink-dist_2.11-1.13.3.jar:1.13.3]
at
org.apache.flink.runtime.entrypoint.ClusterEntrypoint.lambda$startCluster$1(ClusterEntrypoint.java:189)
~[flink-dist_2.11-1.13.3.jar:1.13.3]
at java.security.AccessController.doPrivileged(Native Method)
~[?:1.8.0_171]
at javax.security.auth.Subject.doAs(Subject.java:422) ~[?:1.8.0_171]
at
org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1754)
~[flink-shaded-hadoop-2-uber-2.7.5-9.0.jar:2.7.5-9.0]
at
org.apache.flink.runtime.security.contexts.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41)
~[flink-dist_2.11-1.13.3.jar:1.13.3]
at
org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startCluster(ClusterEntrypoint.java:186)
~[flink-dist_2.11-1.13.3.jar:1.13.3]
... 2 more
Caused by: java.net.BindException: Could not start rest endpoint on any port in
port range 8081
at
org.apache.flink.runtime.rest.RestServerEndpoint.start(RestServerEndpoint.java:234)
~[flink-dist_2.11-1.13.3.jar:1.13.3]
at
org.apache.flink.runtime.entrypoint.component.DefaultDispatcherResourceManagerComponentFactory.create(DefaultDispatcherResourceManagerComponentFactory.java:172)
~[flink-dist_2.11-1.13.3.jar:1.13.3]
at
org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runCluster(ClusterEntrypoint.java:250)
~[flink-dist_2.11-1.13.3.jar:1.13.3]
at
org.apache.flink.runtime.entrypoint.ClusterEntrypoint.lambda$startCluster$1(ClusterEntrypoint.java:189)
~[flink-dist_2.11-1.13.3.jar:1.13.3]
at java.security.AccessController.doPrivileged(Native Method)
~[?:1.8.0_171]
at javax.security.auth.Subject.doAs(Subject.java:422) ~[?:1.8.0_171]
at
org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1754)
~[flink-shaded-hadoop-2-uber-2.7.5-9.0.jar:2.7.5-9.0]
at
org.apache.flink.runtime.security.contexts.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41)
~[flink-dist_2.11-1.13.3.jar:1.13.3]
at
org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startCluster(ClusterEntrypoint.java:186)
~[flink-dist_2.11-1.13.3.jar:1.13.3]
... 2 more