You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by "junjie.miao@goupwith.com" <ju...@goupwith.com> on 2022/11/21 11:03:43 UTC

flink1.15.2无论blob.server.port设置什么端口范围，都会报错

flink1.15.2无论blob.server.port设置什么端口范围，都会报错。
如设置blob.server.port=“50100-50200”时报错：
Caused by: java.io.IOException: Unable to open BLOB Server in specified port range: 50100
    at org.apache.flink.runtime.blob.BlobServer.<init>(BlobServer.java:229)
    at org.apache.flink.runtime.blob.BlobUtils.createBlobServer(BlobUtils.java:129)
    at org.apache.flink.runtime.minicluster.MiniCluster.start(MiniCluster.java:411)
    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:2095)
    at org.apache.flink.table.planner.delegation.DefaultExecutor.executeAsync(DefaultExecutor.java:95)
    at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:804)
    ... 48 common frames omitted
不知道是什么情况导致的，且这些端口都是空闲的。

Re: flink1.15.2无论blob.server.port设置什么端口范围，都会报错

Posted by yidan zhao <hi...@gmail.com>.
日志太少，建议开启debug日志后，发出来完整日志看看。

junjie.miao@goupwith.com <ju...@goupwith.com> 于2022年11月21日周一 19:04写道：
>
> flink1.15.2无论blob.server.port设置什么端口范围，都会报错。
> 如设置blob.server.port=“50100-50200”时报错：
> Caused by: java.io.IOException: Unable to open BLOB Server in specified port range: 50100
>     at org.apache.flink.runtime.blob.BlobServer.<init>(BlobServer.java:229)
>     at org.apache.flink.runtime.blob.BlobUtils.createBlobServer(BlobUtils.java:129)
>     at org.apache.flink.runtime.minicluster.MiniCluster.start(MiniCluster.java:411)
>     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:2095)
>     at org.apache.flink.table.planner.delegation.DefaultExecutor.executeAsync(DefaultExecutor.java:95)
>     at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:804)
>     ... 48 common frames omitted
> 不知道是什么情况导致的，且这些端口都是空闲的。