我已经上传了一个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
我遵循他们的官方文件以供参考。我哪里出错了?任何帮助都将不胜感激。
1条答案
按热度按时间km0tfn4u1#
确保jar文件位于temp目录中。路径中有一个“:”,对吗?
我最近学习了restapi,并成功地提交了我的工作和post请求
您还可以通过flink dashboard提交作业,并通过网络选项卡上的chrome devtoos检测正确的url(或类似的内容)