我有 jar 文件已经在 flink 集群中上传了。我正在使用 flink 1.6.0
这是我上传jar文件后的结果
address "http://localhost:8081"
files
0
id "1d6dc437-bd5f-4147-a37e-b1d40d425a99_NicoWordCount.jar"
name "NicoWordCount.jar"
uploaded 1537174925000
entry
0
name "WordCount"
description null
当我运行以下网址时
"http://localhost:8081/jars/1d6dc437-bd5f-4147-a37e-b1d40d425a99_NicoWordCount.jar/run" 它返回:失败:404 未找到
当我跑步时
"http://localhost:8081/jars/1d6dc437-bd5f-4147-a37e-b1d40d425a99_NicoWordCount.jar/plan"
它返回一个结果。
当我在flink仪表板中运行NicoWordCount.jar时,它也运行良好并给出了预期的结果。
我做错了什么?
你使用哪种HTTP方法?
运行应使用POST
执行。有关 flink API 的更多信息,请查看此文档。