文档
测试

add-k8sSession

POST
http://172.16.48.100:32219/application

接口描述

作业管理(application)界面新建(Add New)接口-kubernetes Session模式

请求参数

参数名
类型
描述
必填
applicationName
string
示例:flink-test-161-k8sSe-081701
必填
description
string
示例:easyDoc测试
必填
projectId
string
示例:2c90dc478165049501816505a3940000
必填
configDef
string
示例:{"applicationType":"FLINK","executionMode":"KUBERNETES_SESSION","flinkVersion":"flink-1.13.6","jobJar":"2c90d27681db8a6a0181db8ac8bf0000","programMain":"org.apache.flink.streaming.examples.windowing.TopSpeedWindowing","kubernetesClusterId":"flink-on-k8s3","parallelism":"1","taskSlots":"1","totalMemoryOptions":{"jobmanager.memory.process.size":"1G","taskmanager.memory.process.size":"2G","tas...
必填

说明 / 示例

json数据 ```json { "applicationName": "flink-test-161-k8sSe-081701", "description": "easyDoc测试", "projectId": "2c90dc478165049501816505a3940000", "configDef": "{\"applicationType\":\"FLINK\",\"executionMode\":\"KUBERNETES_SESSION\",\"flinkVersion\":\"flink-1.13.6\",\"jobJar\":\"2c90d27681db8a6a0181db8ac8bf0000\",\"programMain\":\"org.apache.flink.streaming.examples.windowing.TopSpeedWindowing\",\"kubernetesClusterId\":\"flink-on-k8s3\",\"parallelism\":\"1\",\"taskSlots\":\"1\",\"totalMemoryOptions\":{\"jobmanager.memory.process.size\":\"1G\",\"taskmanager.memory.process.size\":\"2G\",\"taskmanager.memory.flink.size\":\"1G\"},\"jobManagerMemoryOptions\":{\"jobmanager.memory.heap.size\":\"128m\"},\"taskManagerMemoryOptions\":{},\"dynamicOptions\":\"\",\"programArgs\":\"\",\"programResourceFiles\":\"\"}" } ``` configDef参数描述 ```json "configDef": "{\"applicationType\":\"FLINK\",\"executionMode\":\"KUBERNETES_SESSION\",\"flinkVersion\":\"flink-1.13.6\",\"jobJar\":\"2c90d27681db8a6a0181db8ac8bf0000\",\"programMain\":\"org.apache.flink.streaming.examples.windowing.TopSpeedWindowing\",\"kubernetesClusterId\":\"flink-on-k8s3\",\"parallelism\":\"1\",\"taskSlots\":\"1\",\"totalMemoryOptions\":{\"jobmanager.memory.process.size\":\"1G\",\"taskmanager.memory.process.size\":\"2G\",\"taskmanager.memory.flink.size\":\"1G\"},\"jobManagerMemoryOptions\":{\"jobmanager.memory.heap.size\":\"128m\"},\"taskManagerMemoryOptions\":{},\"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. kubernetesClusterId kubernetes的两种模式中所需,KUBERNETES_SESSION模式下值为下拉选框,对应setting中k8s的clusterName KUBERNETES_APPLICATION模式下为用户自定义,一般与applicationName相同即可,注意这个String仅支持数字、小写字母、"-"三种 注:其他字段值无特殊说明采用测试用例值即可!!!