当前位置:   article > 正文

Flink 运行作业报错 IOException: Could not connect to BlobServer at address localhost/127.0.0.1:37062_caused by: java.io.ioexception: could not connect

caused by: java.io.ioexception: could not connect to blobserver at address l

问题: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)

  1. # 需要写为0.0.0.0
  2. jobmanager.bind-host: 0.0.0.0
  3. # 固定一个端口
  4. blob.server.port: 45579

Linux查看端口号是否被占用:

  1. (base) [root@test002 24-06-14 18:01:07 ~ #] netstat -tuln|grep 45579
  2. (base) [root@test002 24-06-14 18:01:17 ~ #] netstat -tuln|grep 8081
  3. tcp6 0 0 172.xx.xxx.xxx:8081 :::* LISTEN

WARN Exception报错详情: 

  1. java.util.concurrent.CompletionException: org.apache.flink.runtime.rest.util.RestClientException: [org.apache.flink.runtime.rest.handler.RestHandlerException: Could not upload job files.
  2. at org.apache.flink.runtime.rest.handler.job.JobSubmitHandler.lambda$uploadJobGraphFiles$4(JobSubmitHandler.java:201)
  3. at java.util.concurrent.CompletableFuture.biApply(CompletableFuture.java:1105)
  4. at java.util.concurrent.CompletableFuture$BiApply.tryFire(CompletableFuture.java:1070)
  5. at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
  6. at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1595)
  7. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
  8. at java.util.concurrent.FutureTask.run(FutureTask.java:266)
  9. at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
  10. at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
  11. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
  12. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
  13. at java.lang.Thread.run(Thread.java:748)
  14. Caused by: org.apache.flink.util.FlinkException: Could not upload job files.
  15. at org.apache.flink.runtime.client.ClientUtils.uploadJobGraphFiles(ClientUtils.java:86)
  16. at org.apache.flink.runtime.rest.handler.job.JobSubmitHandler.lambda$uploadJobGraphFiles$4(JobSubmitHandler.java:195)
  17. ... 11 more
  18. Caused by: java.io.IOException: Could not connect to BlobServer at address localhost/127.0.0.1:37062
  19. at org.apache.flink.runtime.blob.BlobClient.<init>(BlobClient.java:103)
  20. at org.apache.flink.runtime.rest.handler.job.JobSubmitHandler.lambda$null$3(JobSubmitHandler.java:199)
  21. at org.apache.flink.runtime.client.ClientUtils.uploadJobGraphFiles(ClientUtils.java:82)
  22. ... 12 more
  23. Caused by: java.net.ConnectException: 拒绝连接 (Connection refused)
  24. at java.net.PlainSocketImpl.socketConnect(Native Method)
  25. at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)
  26. at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
  27. at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
  28. at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
  29. at java.net.Socket.connect(Socket.java:589)
  30. at org.apache.flink.runtime.blob.BlobClient.<init>(BlobClient.java:97)
  31. ... 14 more
  32. ]
  33. at java.util.concurrent.CompletableFuture.encodeRelay(CompletableFuture.java:326) ~[?:1.8.0_181]
  34. at java.util.concurrent.CompletableFuture.completeRelay(CompletableFuture.java:338) ~[?:1.8.0_181]
  35. at java.util.concurrent.CompletableFuture.uniRelay(CompletableFuture.java:911) [?:1.8.0_181]
  36. at java.util.concurrent.CompletableFuture.uniCompose(CompletableFuture.java:953) [?:1.8.0_181]
  37. at java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:926) [?:1.8.0_181]
  38. at java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:442) [?:1.8.0_181]
  39. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_181]
  40. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_181]
  41. at java.lang.Thread.run(Thread.java:748) [?:1.8.0_181]
  42. Caused by: org.apache.flink.runtime.rest.util.RestClientException: [org.apache.flink.runtime.rest.handler.RestHandlerException: Could not upload job files.
  43. at org.apache.flink.runtime.rest.handler.job.JobSubmitHandler.lambda$uploadJobGraphFiles$4(JobSubmitHandler.java:201)
  44. at java.util.concurrent.CompletableFuture.biApply(CompletableFuture.java:1105)
  45. at java.util.concurrent.CompletableFuture$BiApply.tryFire(CompletableFuture.java:1070)
  46. at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
  47. at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1595)
  48. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
  49. at java.util.concurrent.FutureTask.run(FutureTask.java:266)
  50. at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
  51. at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
  52. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
  53. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
  54. at java.lang.Thread.run(Thread.java:748)
  55. Caused by: org.apache.flink.util.FlinkException: Could not upload job files.
  56. at org.apache.flink.runtime.client.ClientUtils.uploadJobGraphFiles(ClientUtils.java:86)
  57. at org.apache.flink.runtime.rest.handler.job.JobSubmitHandler.lambda$uploadJobGraphFiles$4(JobSubmitHandler.java:195)
  58. ... 11 more
  59. Caused by: java.io.IOException: Could not connect to BlobServer at address localhost/127.0.0.1:37062
  60. at org.apache.flink.runtime.blob.BlobClient.<init>(BlobClient.java:103)
  61. at org.apache.flink.runtime.rest.handler.job.JobSubmitHandler.lambda$null$3(JobSubmitHandler.java:199)
  62. at org.apache.flink.runtime.client.ClientUtils.uploadJobGraphFiles(ClientUtils.java:82)
  63. ... 12 more
  64. Caused by: java.net.ConnectException: 拒绝连接 (Connection refused)
  65. at java.net.PlainSocketImpl.socketConnect(Native Method)
  66. at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)
  67. at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
  68. at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
  69. at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
  70. at java.net.Socket.connect(Socket.java:589)
  71. at org.apache.flink.runtime.blob.BlobClient.<init>(BlobClient.java:97)
  72. ... 14 more
  73. ]
  74. at org.apache.flink.runtime.rest.RestClient.parseResponse(RestClient.java:646) ~[flink-dist-1.18.0.jar:1.18.0]
  75. at org.apache.flink.runtime.rest.RestClient.lambda$submitRequest$6(RestClient.java:626) ~[flink-dist-1.18.0.jar:1.18.0]
  76. at java.util.concurrent.CompletableFuture.uniCompose(CompletableFuture.java:952) ~[?:1.8.0_181]
  77. ... 5 more

参考:Flink: Could not connect to BlobServer at address localhost/127.0.0.1:34036-CSDN博客

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/Li_阴宅/article/detail/921446
推荐阅读
相关标签
  

闽ICP备14008679号