如何在 apache flink 1.9 中通过 rest api 传递类路径

Question

我们通过 cli 成功地为作业加注星标，如下所示：

./bin/flink run -p 1 -C file://tmp/test-fatjar.jar -c ru.test.TestApps test.jar * some arguments*

此外，我们可以通过 API 成功运行此作业，如果我们注册 fatjar，json 如下所示：

{ 
"entryClass": "ru.test.TestApps",
"parallelism": "1",
"programArgsList" : [ *** cut *** ]
}

如何通过 API 传递类路径(参数 -C(？

谢谢。

Answer 1

没有等效于 CLI 的通用类路径选项。REST API 总是希望你使用一个胖罐子。由于您的示例也使用胖罐，因此我会指出一般流程：

1. 用/jars/upload 上传你的胖罐子。响应包含文件名 (=jarid(。
2. 发布到/jars/：jarid/run 以开始您的工作。响应包含 jobid，可用于查询状态和取消。