Apache Flink 1.9如何通过REST API传递Classpath参数

要在Flink REST API中对应CLI里的-C参数，你需要在作业运行的JSON请求中添加classpaths字段——这是一个字符串数组，专门用来指定额外的类路径资源，和CLI的-C作用完全匹配。

修改后的请求JSON示例 #

把你原来的请求加上classpaths字段，就像这样：

{
  "entryClass": "ru.test.TestApps",
  "parallelism": "1",
  "programArgsList": ["some arguments"],
  "classpaths": ["file://tmp/test-fatjar.jar"]
}

关键说明 #

• 如果需要添加多个额外类路径，只需要把每个路径都加入classpaths数组即可，比如：

  "classpaths": ["file://tmp/test-fatjar.jar", "hdfs:///path/to/another-lib.jar"]
  

• 路径的格式要和CLI中使用的保持一致，比如本地文件用file://前缀、HDFS文件用对应的HDFS路径等，Flink会按同样的逻辑加载这些类路径资源。

内容的提问来源于stack exchange，提问作者Aleksei Korolev