如何使用 Apache Flink 中上传的 jar 提交作业

Question

我已经通过 curl 的 HTTP Post 请求将一个 jar(通过字数统计 java 程序生成(上传到Apache Flink Web 控制台，并且 get jars api 显示了上传的 jar。

当我尝试使用该jar提交作业时，它会抛出此错误：

由以下原因引起：org.apache.flink.client.program.ProgramInvocationException： JAR 文件不存在 '/tmp/flink-web-8aa36f99-87fb-4fbc-b155-237fd833fc32/：949611ce-345a-4cd5-986b-8ff9b0700852_WordCount.jar'

这是我的 POST 请求的样子：

http://localhost:8081/jars/:949611ce-345a-4cd5-986b-8ff9b0700852_WordCount.jar/run

我关注了他们的官方文档以供参考。我哪里出错了？任何帮助将不胜感激。

Answer 1

确保 jar 文件位于临时目录中。路径中有一个"："，正确吗？

我最近学习了 REST API，并通过 POST 请求成功提交了我的工作

http://host:port/jars/29525e98-3ece-49c1-85d1-5301a5a38900_myjob.jar/run?allowNonRestoredState=false&entry-class=&parallelism=&program-args=&savepointPath=

您也可以通过 Flink 仪表板提交作业，并通过 Chrome DevToos 在网络选项卡(或类似的东西(检测正确的网址