Flink rest api 错误：请求与预期格式 JarRunRequestBody 不匹配

Question

尝试使用下面的 rest api 远程运行 flink 作业，但它抛出错误

curl -X POST -H 'Content-Type: application/json' --data '
{
    "type": "object",
    "id": "urn:jsonschema:org:apache:flink:runtime:webmonitor:handlers:JarRunRequestBody",
    "properties": {
    "programArgsList" : {
      "type" : "array",
      "items" : [
        "input-kafka-server": "****",
        "input-kafka-topics": "****",
        "input-job-name": "****"
      
    }
  }
}
' http://x.x.x.x:8081/jars/810ac968-5d5f-450d-aafc-22655238d617.jar/run

{"errors":["请求与预期格式 JarRunRequestBody 不匹配。"]}

Answer 1

您在此处找到的 jar run 处理程序的请求正文的描述是jar run 消息的JSON 模式规范。您需要在请求中指定的只是propertiesand 而不是"type"and"id"字段。因此，您的请求应如下所示：

curl -X POST -H 'Content-Type: application/json' --data '
{
  "programArgsList" : [
    "--input-kafka-server",
    "value-input-kafka-server",
    "--input-kafka-topics",
    "value-kafka-topics",
    "--input-job-name",
    "value-job-name"
  ],
"parallelism": 30
}
' http://x.x.x.x:8081/jars/810ac968-5d5f-450d-aafc-22655238d617.jar/run