赞
踩
问题:flink安装完成,首次运行作业报错 IOException: Could not connect to BlobServer at address localhost/127.0.0.1:37062
Caused by: java.io.IOException: Could not connect to BlobServer at address localhost/127.0.0.1:37062
解决:将 flink/conf/flink-conf.yaml 里的 bind ip 都改成 0.0.0.0。重启flink cluster
(可选,增加一个BlobServer服务固定端口号 blob.server.port: 45579)
- # 需要写为0.0.0.0
- jobmanager.bind-host: 0.0.0.0
- # 固定一个端口
- blob.server.port: 45579
Linux查看端口号是否被占用:
- (base) [root@test002 24-06-14 18:01:07 ~ #] netstat -tuln|grep 45579
- (base) [root@test002 24-06-14 18:01:17 ~ #] netstat -tuln|grep 8081
- tcp6 0 0 172.xx.xxx.xxx:8081 :::* LISTEN
WARN Exception报错详情:
- java.util.concurrent.CompletionException: org.apache.flink.runtime.rest.util.RestClientException: [org.apache.flink.runtime.rest.handler.RestHandlerException: Could not upload job files.
- at org.apache.flink.runtime.rest.handler.job.JobSubmitHandler.lambda$uploadJobGraphFiles$4(JobSubmitHandler.java:201)
- at java.util.concurrent.CompletableFuture.biApply(CompletableFuture.java:1105)
- at java.util.concurrent.CompletableFuture$BiApply.tryFire(CompletableFuture.java:1070)
- at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
- at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1595)
- at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
- at java.util.concurrent.FutureTask.run(FutureTask.java:266)
- at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
- at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
- at java.lang.Thread.run(Thread.java:748)
- Caused by: org.apache.flink.util.FlinkException: Could not upload job files.
- at org.apache.flink.runtime.client.ClientUtils.uploadJobGraphFiles(ClientUtils.java:86)
- at org.apache.flink.runtime.rest.handler.job.JobSubmitHandler.lambda$uploadJobGraphFiles$4(JobSubmitHandler.java:195)
- ... 11 more
- Caused by: java.io.IOException: Could not connect to BlobServer at address localhost/127.0.0.1:37062
- at org.apache.flink.runtime.blob.BlobClient.<init>(BlobClient.java:103)
- at org.apache.flink.runtime.rest.handler.job.JobSubmitHandler.lambda$null$3(JobSubmitHandler.java:199)
- at org.apache.flink.runtime.client.ClientUtils.uploadJobGraphFiles(ClientUtils.java:82)
- ... 12 more
- Caused by: java.net.ConnectException: 拒绝连接 (Connection refused)
- at java.net.PlainSocketImpl.socketConnect(Native Method)
- at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)
- at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
- at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
- at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
- at java.net.Socket.connect(Socket.java:589)
- at org.apache.flink.runtime.blob.BlobClient.<init>(BlobClient.java:97)
- ... 14 more
- ]
- at java.util.concurrent.CompletableFuture.encodeRelay(CompletableFuture.java:326) ~[?:1.8.0_181]
- at java.util.concurrent.CompletableFuture.completeRelay(CompletableFuture.java:338) ~[?:1.8.0_181]
- at java.util.concurrent.CompletableFuture.uniRelay(CompletableFuture.java:911) [?:1.8.0_181]
- at java.util.concurrent.CompletableFuture.uniCompose(CompletableFuture.java:953) [?:1.8.0_181]
- at java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:926) [?:1.8.0_181]
- at java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:442) [?:1.8.0_181]
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_181]
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_181]
- at java.lang.Thread.run(Thread.java:748) [?:1.8.0_181]
- Caused by: org.apache.flink.runtime.rest.util.RestClientException: [org.apache.flink.runtime.rest.handler.RestHandlerException: Could not upload job files.
- at org.apache.flink.runtime.rest.handler.job.JobSubmitHandler.lambda$uploadJobGraphFiles$4(JobSubmitHandler.java:201)
- at java.util.concurrent.CompletableFuture.biApply(CompletableFuture.java:1105)
- at java.util.concurrent.CompletableFuture$BiApply.tryFire(CompletableFuture.java:1070)
- at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
- at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1595)
- at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
- at java.util.concurrent.FutureTask.run(FutureTask.java:266)
- at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
- at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
- at java.lang.Thread.run(Thread.java:748)
- Caused by: org.apache.flink.util.FlinkException: Could not upload job files.
- at org.apache.flink.runtime.client.ClientUtils.uploadJobGraphFiles(ClientUtils.java:86)
- at org.apache.flink.runtime.rest.handler.job.JobSubmitHandler.lambda$uploadJobGraphFiles$4(JobSubmitHandler.java:195)
- ... 11 more
- Caused by: java.io.IOException: Could not connect to BlobServer at address localhost/127.0.0.1:37062
- at org.apache.flink.runtime.blob.BlobClient.<init>(BlobClient.java:103)
- at org.apache.flink.runtime.rest.handler.job.JobSubmitHandler.lambda$null$3(JobSubmitHandler.java:199)
- at org.apache.flink.runtime.client.ClientUtils.uploadJobGraphFiles(ClientUtils.java:82)
- ... 12 more
- Caused by: java.net.ConnectException: 拒绝连接 (Connection refused)
- at java.net.PlainSocketImpl.socketConnect(Native Method)
- at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)
- at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
- at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
- at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
- at java.net.Socket.connect(Socket.java:589)
- at org.apache.flink.runtime.blob.BlobClient.<init>(BlobClient.java:97)
- ... 14 more
- ]
- at org.apache.flink.runtime.rest.RestClient.parseResponse(RestClient.java:646) ~[flink-dist-1.18.0.jar:1.18.0]
- at org.apache.flink.runtime.rest.RestClient.lambda$submitRequest$6(RestClient.java:626) ~[flink-dist-1.18.0.jar:1.18.0]
- at java.util.concurrent.CompletableFuture.uniCompose(CompletableFuture.java:952) ~[?:1.8.0_181]
- ... 5 more
参考:Flink: Could not connect to BlobServer at address localhost/127.0.0.1:34036-CSDN博客
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。