Flink报错： java.net.BindException: Could not start rest endpoint on any port in po

网络 02-07 8191

项目场景：

Flink算子执行报错： Caused by: java.net.BindException: Could not start rest endpoint on any port in port range 10000 ?? ?at org.apache.flink.runtime.rest.RestServerEndpoint.start(RestServerEndpoint.java:234) ?? ?at org.apache.flink.runtime.entrypoint.component.DefaultDispatcherResourceManagerComponentFactory.create(DefaultDispatcherResourceManagerComponentFactory.java:172) ?? ?... 11 more ?

问题描述：

具体的报错日志：

org.apache.flink.util.FlinkException: Could not create the DispatcherResourceManagerComponent. ?? ?at org.apache.flink.runtime.entrypoint.component.DefaultDispatcherResourceManagerComponentFactory.create(DefaultDispatcherResourceManagerComponentFactory.java:275) ?? ?at org.apache.flink.runtime.minicluster.MiniCluster.createDispatcherResourceManagerComponents(MiniCluster.java:463) ?? ?at org.apache.flink.runtime.minicluster.MiniCluster.setupDispatcherResourceManagerComponents(MiniCluster.java:422) ?? ?at org.apache.flink.runtime.minicluster.MiniCluster.start(MiniCluster.java:366) ?? ?at org.apache.flink.client.program.PerJobMiniClusterFactory.submitJob(PerJobMiniClusterFactory.java:75) ?? ?at org.apache.flink.client.deployment.executors.LocalExecutor.execute(LocalExecutor.java:85) ?? ?at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:1957) ?? ?at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1848) ?? ?at org.apache.flink.streaming.api.environment.LocalStreamEnvironment.execute(LocalStreamEnvironment.java:69) ?? ?at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1834) ?? ?at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1817) ?? ?at com.atguigu.chapter05.transform.Flink01_MapFunction.main(Flink01_MapFunction.java:34) Caused by: java.net.BindException: Could not start rest endpoint on any port in port range 10000 ?? ?at org.apache.flink.runtime.rest.RestServerEndpoint.start(RestServerEndpoint.java:234) ?? ?at org.apache.flink.runtime.entrypoint.component.DefaultDispatcherResourceManagerComponentFactory.create(DefaultDispatcherResourceManagerComponentFactory.java:172) ?? ?... 11 more

原因分析：

这个提示十分明显，就是port端口的问题导致的。

conf.setInteger("rest.port", 10000);

代码中我设置的是10000，发现此端口被占用了。

解决方案：

修改一下端口即可。

conf.setInteger("rest.port", 9999);

问题解决。