对正在运行的作业进行参数或资源的动态更新。
调试
您可以在OpenAPI Explorer中直接运行该接口,免去您计算签名的困扰。运行成功后,OpenAPI Explorer可以自动生成SDK代码示例。
授权信息
当前API暂无授权信息透出。
请求语法
POST /api/v2/namespaces/{namespace}/jobs/{jobId}:hotUpdate
请求参数
名称 | 类型 | 必填 | 描述 | 示例值 |
---|---|---|---|---|
workspace | string | 是 | 工作空间 ID。 | a14bd5d90a**** |
namespace | string | 是 | 项目空间名称。 | default-namespace |
jobId | string | 是 | 作业实例 ID。 | 88a8fc49-e090-430a-85d8-3ee8c79c**** |
返回参数
示例
正常返回示例
JSON
格式
{
"requestId": "CBC799F0-AS7S-1D30-8A4F-882ED4DD****",
"success": true,
"httpCode": 200,
"errorCode": "\"\"",
"errorMessage": "\"\"",
"data": {
"jobHotUpdateId": "123hashd****",
"jobId": "5af678c0-7db0-4650-94c2-d2604f0a****",
"targetResourceSetting": {
"flinkConf": {
"test": "test",
"test2": 1
},
"batchResourceSetting": {
"maxSlot": 10,
"basicResourceSetting": {
"parallelism": 4,
"jobmanagerResourceSettingSpec": {
"cpu": 2,
"memory": "4 GiB"
},
"taskmanagerResourceSettingSpec": {
"cpu": 2,
"memory": "4 GiB"
}
}
},
"streamingResourceSetting": {
"resourceSettingMode": "EXPERT",
"expertResourceSetting": {
"jobmanagerResourceSettingSpec": {
"cpu": 2,
"memory": "4 GiB"
},
"resourcePlan": "{\\\"ssgProfiles\\\":[{\\\"name\\\":\\\"default\\\",\\\"cpu\\\":1.13,\\\"heap\\\":\\\"1 gb\\\",\\\"offHeap\\\":\\\"32 mb\\\",\\\"managed\\\":{},\\\"extended\\\":{}}],\\\"nodes\\\":[{\\\"id\\\":1,\\\"type\\\":\\\"StreamExecTableSourceScan\\\",\\\"desc\\\":\\\"Source: datagen_source[78]\\\",\\\"profile\\\":{\\\"group\\\":\\\"default\\\",\\\"parallelism\\\":1,\\\"maxParallelism\\\":32768,\\\"minParallelism\\\":1}},{\\\"id\\\":2,\\\"type\\\":\\\"StreamExecSink\\\",\\\"desc\\\":\\\"Sink: blackhole_sink[79]\\\",\\\"profile\\\":{\\\"group\\\":\\\"default\\\",\\\"parallelism\\\":1,\\\"maxParallelism\\\":32768,\\\"minParallelism\\\":1}}],\\\"edges\\\":[{\\\"source\\\":1,\\\"target\\\":2,\\\"mode\\\":\\\"PIPELINED\\\",\\\"strategy\\\":\\\"FORWARD\\\"}],\\\"vertices\\\":{\\\"717c7b8afebbfb7137f6f0f99beb2a94\\\":[1,2]}}"
},
"basicResourceSetting": {
"parallelism": 4
}
}
},
"hotUpdateParams": {
"rescaleJobParam": {
"jobParallelism": 10
},
"updateJobConfigParam": {
"newFlinkConf": {
"test": "test",
"test2": 1
}
}
},
"status": {
"status": "HOT_UPDATED",
"requestId": "CBC799F0-AS7S-1D30-8A4F-882ED4DD****",
"failure": {
"reason": "“”",
"message": "“”",
"failureSeverity": "LOW"
}
}
}
}
错误码
访问错误中心查看更多错误码。