API tools faq
paste
Guest User

Flink Error Log

a guest
Jun 30th, 2023
40
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 7.55 KB | Help | 0 0
raw download clone embed print report
  1. The program finished with the following exception:
  2.  
  3. org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: java.util.concurrent.ExecutionException: org.apache.flink.runtime.client.JobSubmissionException: Failed to submit JobGraph.
  4. at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:372)
  5. at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:222)
  6. at org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:105)
  7. at org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:851)
  8. at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:245)
  9. at org.apache.flink.client.cli.CliFrontend.parseAndRun(CliFrontend.java:1095)
  10. at org.apache.flink.client.cli.CliFrontend.lambda$mainInternal$9(CliFrontend.java:1189)
  11. at org.apache.flink.runtime.security.contexts.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:28)
  12. at org.apache.flink.client.cli.CliFrontend.mainInternal(CliFrontend.java:1189)
  13. at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1157)
  14. Caused by: java.lang.RuntimeException: java.util.concurrent.ExecutionException: org.apache.flink.runtime.client.JobSubmissionException: Failed to submit JobGraph.
  15. at org.apache.flink.util.ExceptionUtils.rethrow(ExceptionUtils.java:321)
  16. at org.apache.flink.api.java.ExecutionEnvironment.executeAsync(ExecutionEnvironment.java:1061)
  17. at org.apache.flink.client.program.ContextEnvironment.executeAsync(ContextEnvironment.java:144)
  18. at org.apache.flink.client.program.ContextEnvironment.execute(ContextEnvironment.java:73)
  19. at org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:942)
  20. at org.apache.flink.api.java.DataSet.collect(DataSet.java:417)
  21. at org.apache.flink.api.java.DataSet.print(DataSet.java:1748)
  22. at org.apache.flink.examples.java.wordcount.WordCount.main(WordCount.java:96)
  23. at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  24. at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
  25. at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  26. at java.base/java.lang.reflect.Method.invoke(Method.java:566)
  27. at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:355)
  28. ... 9 more
  29. Caused by: java.util.concurrent.ExecutionException: org.apache.flink.runtime.client.JobSubmissionException: Failed to submit JobGraph.
  30. at java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:395)
  31. at java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1999)
  32. at org.apache.flink.api.java.ExecutionEnvironment.executeAsync(ExecutionEnvironment.java:1056)
  33. ... 20 more
  34. Caused by: org.apache.flink.runtime.client.JobSubmissionException: Failed to submit JobGraph.
  35. at org.apache.flink.client.program.rest.RestClusterClient.lambda$submitJob$11(RestClusterClient.java:451)
  36. at java.base/java.util.concurrent.CompletableFuture.uniExceptionally(CompletableFuture.java:986)
  37. at java.base/java.util.concurrent.CompletableFuture$UniExceptionally.tryFire(CompletableFuture.java:970)
  38. at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
  39. at java.base/java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2088)
  40. at org.apache.flink.util.concurrent.FutureUtils.lambda$retryOperationWithDelay$6(FutureUtils.java:272)
  41. at java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859)
  42. at java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837)
  43. at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
  44. at java.base/java.util.concurrent.CompletableFuture.postFire(CompletableFuture.java:610)
  45. at java.base/java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:1085)
  46. at java.base/java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:478)
  47. at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
  48. at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
  49. at java.base/java.lang.Thread.run(Thread.java:829)
  50. Caused by: org.apache.flink.runtime.rest.util.RestClientException: [org.apache.flink.runtime.rest.handler.RestHandlerException: Could not upload job files.
  51. at org.apache.flink.runtime.rest.handler.job.JobSubmitHandler.lambda$uploadJobGraphFiles$4(JobSubmitHandler.java:201)
  52. at java.base/java.util.concurrent.CompletableFuture.biApply(CompletableFuture.java:1236)
  53. at java.base/java.util.concurrent.CompletableFuture$BiApply.tryFire(CompletableFuture.java:1205)
  54. at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
  55. at java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1705)
  56. at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
  57. at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
  58. at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
  59. at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
  60. at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
  61. at java.base/java.lang.Thread.run(Thread.java:829)
  62. Caused by: org.apache.flink.util.FlinkException: Could not upload job files.
  63. at org.apache.flink.runtime.client.ClientUtils.uploadJobGraphFiles(ClientUtils.java:86)
  64. at org.apache.flink.runtime.rest.handler.job.JobSubmitHandler.lambda$uploadJobGraphFiles$4(JobSubmitHandler.java:195)
  65. ... 10 more
  66. Caused by: java.io.IOException: Could not connect to BlobServer at address localhost/127.0.0.1:37101
  67. at org.apache.flink.runtime.blob.BlobClient.<init>(BlobClient.java:103)
  68. at org.apache.flink.runtime.rest.handler.job.JobSubmitHandler.lambda$null$3(JobSubmitHandler.java:199)
  69. at org.apache.flink.runtime.client.ClientUtils.uploadJobGraphFiles(ClientUtils.java:82)
  70. ... 11 more
  71. Caused by: java.net.ConnectException: Connection refused (Connection refused)
  72. at java.base/java.net.PlainSocketImpl.socketConnect(Native Method)
  73. at java.base/java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:412)
  74. at java.base/java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:255)
  75. at java.base/java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:237)
  76. at java.base/java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
  77. at java.base/java.net.Socket.connect(Socket.java:609)
  78. at org.apache.flink.runtime.blob.BlobClient.<init>(BlobClient.java:97)
  79. ... 13 more
  80. ]
  81. at org.apache.flink.runtime.rest.RestClient.parseResponse(RestClient.java:536)
  82. at org.apache.flink.runtime.rest.RestClient.lambda$submitRequest$3(RestClient.java:516)
  83. at java.base/java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:1072)
  84. ... 4 more
Advertisement
Add Comment
Please, Sign In to add comment
Public Pastes
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!