文档
测试

add-yarnPerjob

POST
http://172.16.48.100:32219/application

接口描述

作业管理(application)界面新建(Add New)接口-yarn Per-Job模式

请求参数

参数名
类型
描述
必填
applicationName
string
示例:flink_test_161_yarnPer_081701
必填
description
string
示例:easyDoc测试
必填
projectId
string
示例:2c90dc478165049501816505a3940000
必填
configDef
string
示例:{"applicationType":"FLINK","executionMode":"YARN_PER_JOB","flinkVersion":"1.13.6","jobJar":"2c90d27681db8a6a0181db8ac8bf0000","programMain":"org.apache.flink.streaming.examples.windowing.TopSpeedWindowing","jobName":"flink_test_161_yarnPer_081701","yarnQueue":"prod","parallelism":"1","taskSlots":"1","totalMemoryOptions":{"jobmanager.memory.process.size":"1G","taskmanager.memory.process.size...
必填

说明 / 示例

json数据 ```json { "applicationName": "flink_test_161_yarnPer_081701", "description": "easyDoc测试", "projectId":"2c90dc478165049501816505a3940000", "configDef": "{\"applicationType\":\"FLINK\",\"executionMode\":\"YARN_PER_JOB\",\"flinkVersion\":\"1.13.6\",\"jobJar\":\"2c90d27681db8a6a0181db8ac8bf0000\",\"programMain\":\"org.apache.flink.streaming.examples.windowing.TopSpeedWindowing\",\"jobName\":\"flink_test_161_yarnPer_081701\",\"yarnQueue\":\"prod\",\"parallelism\":\"1\",\"taskSlots\":\"1\",\"totalMemoryOptions\":{\"jobmanager.memory.process.size\":\"1G\",\"taskmanager.memory.process.size\":\"2G\"},\"jobManagerMemoryOptions\":{\"jobmanager.memory.heap.size\":\"128m\",\"jobmanager.memory.off-heap.size\":\"128m\",\"jobmanager.memory.jvm-metaspace.size\":\"256m\",\"jobmanager.memory.jvm-overhead.fraction\":\"0.1\",\"jobmanager.memory.jvm-overhead.max\":\"1G\",\"jobmanager.memory.jvm-overhead.min\":\"192m\"},\"taskManagerMemoryOptions\":{\"taskmanager.memory.framework.heap.size\":\"128m\",\"taskmanager.memory.framework.off-heap.size\":\"128m\",\"taskmanager.memory.managed.fraction\":\"0.4\",\"taskmanager.memory.jvm-metaspace.size\":\"256m\",\"taskmanager.memory.jvm-overhead.fraction\":\"0.1\",\"taskmanager.memory.jvm-overhead.max\":\"1G\",\"taskmanager.memory.jvm-overhead.min\":\"192m\"},\"dynamicOptions\":\"\",\"programArgs\":\"\",\"programResourceFiles\":\"\"}" } ``` configDef参数描述 ```json "configDef": "{\"applicationType\":\"FLINK\",\"executionMode\":\"YARN_PER_JOB\",\"flinkVersion\":\"1.13.6\",\"jobJar\":\"2c90d27681db8a6a0181db8ac8bf0000\",\"programMain\":\"org.apache.flink.streaming.examples.windowing.TopSpeedWindowing\",\"jobName\":\"flink_test_161_yarnPer_081701\",\"yarnQueue\":\"prod\",\"parallelism\":\"1\",\"taskSlots\":\"1\",\"totalMemoryOptions\":{\"jobmanager.memory.process.size\":\"1G\",\"taskmanager.memory.process.size\":\"2G\"},\"jobManagerMemoryOptions\":{\"jobmanager.memory.heap.size\":\"128m\",\"jobmanager.memory.off-heap.size\":\"128m\",\"jobmanager.memory.jvm-metaspace.size\":\"256m\",\"jobmanager.memory.jvm-overhead.fraction\":\"0.1\",\"jobmanager.memory.jvm-overhead.max\":\"1G\",\"jobmanager.memory.jvm-overhead.min\":\"192m\"},\"taskManagerMemoryOptions\":{\"taskmanager.memory.framework.heap.size\":\"128m\",\"taskmanager.memory.framework.off-heap.size\":\"128m\",\"taskmanager.memory.managed.fraction\":\"0.4\",\"taskmanager.memory.jvm-metaspace.size\":\"256m\",\"taskmanager.memory.jvm-overhead.fraction\":\"0.1\",\"taskmanager.memory.jvm-overhead.max\":\"1G\",\"taskmanager.memory.jvm-overhead.min\":\"192m\"},\"dynamicOptions\":\"\",\"programArgs\":\"\",\"programResourceFiles\":\"\"}" ``` 这些参数即为页面的每一个参数,封装在configDef里发送 1. applicationType 枚举类型目前有FLINK、SPARK两种,前端显示为flink spark 2. executionMode 枚举类型目前有YARN_APPLICATION、YARN_SESSION、YARN_PER_JOB、KUBERNETES_APPLICATION、KUBERNETES_SESSION五种 ,前端显示为yarn application、yarn session、yarn per-job、kubernetes application、kubernetes session 3. flinkVersion 版本对应setting中的version字段 4. jobJar 对应resource中的字段 5. jobName yarn的三种模式中所需,为用户自定义,一般与applicationName相同即可 注:其他字段值无特殊说明采用测试用例值即可!!!