flink on yarn会话模式提交jar包失败Server Response:File upload failed.

Question

今天学习flink on yarn的时候进行会话模式提交任务，出现jar提交失败
启动fkin的yarn-session

bin/yarn-session.sh -d -nm code

进入web页面上传jar包

显示失败

我就进入shell界面尝试命令提交任务

bin/flink run -c wc.WordCountStreamUnbounded jar/flink_study-flink学习.jar

结果报错：

org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: Failed to execute job 'Flink Streaming Job'.
    at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:372)
    at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:222)
    at org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:105)
    at org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:851)
    at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:245)
    at org.apache.flink.client.cli.CliFrontend.parseAndRun(CliFrontend.java:1095)
    at org.apache.flink.client.cli.CliFrontend.lambda$mainInternal$9(CliFrontend.java:1189)
    at java.security.AccessController.doPrivileged(Native Method)
    at javax.security.auth.Subject.doAs(Subject.java:422)
    at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1729)
    at org.apache.flink.runtime.security.contexts.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41)
    at org.apache.flink.client.cli.CliFrontend.mainInternal(CliFrontend.java:1189)
    at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1157)
Caused by: org.apache.flink.util.FlinkException: Failed to execute job 'Flink Streaming Job'.
    at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:2212)
    at org.apache.flink.client.program.StreamContextEnvironment.executeAsync(StreamContextEnvironment.java:189)
    at org.apache.flink.client.program.StreamContextEnvironment.execute(StreamContextEnvironment.java:118)
    at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:2058)
    at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:2036)
    at wc.WordCountStreamUnbounded.main(WordCountStreamUnbounded.java:30)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:355)
    ... 12 more
Caused by: org.apache.flink.runtime.client.JobSubmissionException: Failed to submit JobGraph.
    at org.apache.flink.client.program.rest.RestClusterClient.lambda$submitJob$11(RestClusterClient.java:451)
    at java.util.concurrent.CompletableFuture.uniExceptionally(CompletableFuture.java:870)
    at java.util.concurrent.CompletableFuture$UniExceptionally.tryFire(CompletableFuture.java:852)
    at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
    at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
    at org.apache.flink.util.concurrent.FutureUtils.lambda$retryOperationWithDelay$6(FutureUtils.java:271)
    at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:760)
    at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:736)
    at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
    at java.util.concurrent.CompletableFuture.postFire(CompletableFuture.java:561)
    at java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:929)
    at java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:442)
    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.runtime.rest.util.RestClientException: [File upload failed.]
    at org.apache.flink.runtime.rest.RestClient.parseResponse(RestClient.java:536)
    at org.apache.flink.runtime.rest.RestClient.lambda$submitRequest$3(RestClient.java:516)
    at java.util.concurrent.CompletableFuture.uniCompose(CompletableFuture.java:952)
    at java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:926)
    ... 4 more

主要错误这里

实在不知道哪里问题，有没有这方面法师指点一二

Answer 1

排骨学长（\t） 晚上好🌙🌙🌙
本答案参考ChatGPT-3.5

根据你提供的错误信息，“org.apache.flink.runtime.rest.util.RestClientException: [File upload failed.]”可以看出，jar包上传失败是导致提交任务失败的原因。下面提供一些可能的解决方案：

1. 检查jar包路径：确保你的jar包路径指定正确。可以使用绝对路径或相对路径，但要确保路径能够正确访问到jar包。

2. 检查jar包权限：确保你的jar包对用户有读取权限或执行权限。你可以使用chmod命令添加执行权限。

3. 检查集群环境：确保你的集群环境配置正确，并且Hadoop和Flink版本兼容。可以通过执行hadoop version查看Hadoop的版本，通过执行flink -v查看Flink的版本。

4. 检查网络连接：确保网络连接正常，可以尝试使用curl命令或浏览器访问Web页面来检查网络连接。

5. 检查日志信息：查看Flink的日志信息，可能会提供更详细的错误信息，以便进一步排查问题。

解决方案：

1. 确保jar包路径正确并存在；
2. 检查jar包文件权限；
3. 检查集群环境配置，确保Hadoop和Flink版本兼容；
4. 检查网络连接，确认网络正常；
5. 查看Flink的日志信息，尝试找出更详细的错误信息。

如果仍然无法解决问题，请提供更多的错误信息，以便能够更准确地帮助你解决问题。