如何使用ApacheFlink中上传的jar提交作业？

dfddblmv 于 2021-06-25 发布在 Flink

关注(0)|答案(1)|浏览(350)

我已经上传了一个jar（它是通过wordcountjava程序生成的）到 Apache Flink web控制台通过一个httppost请求通过curl和getjarsapi显示上传的jar。
当我尝试使用该jar提交作业时，它会抛出以下错误：
原因：org.apache.flink.client.program.programinvocationexception:jar文件不存在“/tmp/flink-web-8aa36f99-87fb-4fbc-b155-237fd833fc32/：949611ce-345a-4cd5-986b-8ff9b0700852\u wordcount.jar”
我的post请求如下：

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

我遵循他们的官方文件以供参考。我哪里出错了？任何帮助都将不胜感激。

mapreduce apache-flink flink-streaming apache

来源：https://stackoverflow.com/questions/48303186/how-to-submit-a-job-by-using-an-uploaded-jar-in-apache-flink

1条答案

按热度按时间

km0tfn4u1#

确保jar文件位于temp目录中。路径中有一个“：”，对吗？
我最近学习了restapi，并成功地提交了我的工作和post请求

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

您还可以通过flink dashboard提交作业，并通过网络选项卡上的chrome devtoos检测正确的url（或类似的内容）

赞(0）回复(0）举报 2021-06-25

我来回答

如何使用ApacheFlink中上传的jar提交作业？

1条答案

相关问题

热门标签

最新问答