Flink rest api error: запрос не соответствует ожидаемому формату JarRunRequestBody - PullRequest
Новая
       6

Flink rest api error: запрос не соответствует ожидаемому формату JarRunRequestBody

0 голосов
/ 24 января 2019

Попытка запустить задание Flink удаленно, используя приведенный ниже api rest, но ошибка его выдачи 

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."]}

Заранее спасибо.

1 Ответ

0 голосов
/ 24 января 2019

Описание тела запроса для обработчика запуска jar, которое вы найдете здесь - это спецификация схемы JSON сообщения запуска jar.В вашем запросе необходимо указать только поля properties, а не поля "type" и "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"
  ]
}
' http://x.x.x.x:8081/jars/810ac968-5d5f-450d-aafc-22655238d617.jar/run
...