打开jar文件'/tmp/flink-web-/flink-web-upload‘时出错

Question

我已经创建了一个CICD进程来在flink服务器中部署我的flink应用程序。CD管道能够成功添加Jar，但无法提交jar。我检查了CD日志，发现了我在flink- 500 internal server error日志中检查过的服务器，在那里我发现了这个错误

Error while opening jar file '/tmp/flink-web-<someid>/flink-web-upload'

下面是完整的错误堆栈跟踪

2020-10-23 15:16:10,344 ERROR org.apache.flink.runtime.webmonitor.handlers.JarRunHandler    - Unhandled exception.
org.apache.flink.client.program.ProgramInvocationException: Error while opening jar file '/tmp/flink-web-<id>/flink-web-upload'
at org.apache.flink.client.program.PackagedProgram.checkJarFile(PackagedProgram.java:531)
at org.apache.flink.client.program.PackagedProgram.loadJarFile(PackagedProgram.java:407)
at org.apache.flink.client.program.PackagedProgram.<init>(PackagedProgram.java:133)
at org.apache.flink.client.program.PackagedProgram.<init>(PackagedProgram.java:68)
at org.apache.flink.client.program.PackagedProgram$Builder.build(PackagedProgram.java:590)
at org.apache.flink.runtime.webmonitor.handlers.utils.JarHandlerUtils$JarHandlerContext.toJobGraph(JarHandlerUtils.java:127)
at org.apache.flink.runtime.webmonitor.handlers.JarRunHandler.lambda$getJobGraphAsync$6(JarRunHandler.java:138)
at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1604)
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: java.io.IOException: Error while opening jar file '/tmp/flink-web-<id>/flink-web-upload'
at org.apache.flink.util.JarUtils.checkJarFile(JarUtils.java:57)
at org.apache.flink.client.program.PackagedProgram.checkJarFile(PackagedProgram.java:529)
... 10 more
Caused by: java.io.FileNotFoundException: /tmp/flink-web-<id>/flink-web-upload (Is a directory)
at java.util.zip.ZipFile.open(Native Method)
at java.util.zip.ZipFile.<init>(ZipFile.java:225)
at java.util.zip.ZipFile.<init>(ZipFile.java:155)
at java.util.jar.JarFile.<init>(JarFile.java:166)
at java.util.jar.JarFile.<init>(JarFile.java:130)
at org.apache.flink.util.JarUtils.checkJarFile(JarUtils.java:54)
... 11 more

Answer 1

在我们的例子中，罐子被损坏了。

检查本地文件和群集上的文件的MD5 SUM。