文档首页 > > SDK参考> 使用SDK(JAVA)> 作业管理> 更新自定义作业

更新自定义作业

分享
更新时间: 2019/09/10 GMT+08:00

样例代码

用户可以使用该接口更新已经创建的自定义作业,目前仅支持Jar格式和运行在独享集群中。示例代码如下:

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
// Import classes:
import com.huaweicloud.cs.java.v1.client.ApiException;
import com.huaweicloud.cs.java.v1.JobApi;


JobApi apiInstance = new JobApi(apiClient);//apiClient为初始化CS API客户端时创建
String xProjectId = "xProjectId_example"; // String | project id, 用于不同project取token.
Long jobId = 789L; // Long | 作业ID
Integer managerSpu = 56; // Integer | 用户为作业选择的管理节点SPU数量,Flink自定义作业对应为flink jobmanager数量,Spark自定义作业对应为spark driver数量。
String name = "name_example"; // String | 作业名称
String desc = "desc_example"; // String | 作业描述
Integer clusterId = 56; // Integer | 独享集群资源ID, 当前用户有该独享资源的使用权限
Integer spuNumber = 56; // Integer | 用户为作业选择的SPU数量, 提交Flink自定义作业时需要配置,Spark自定义作业不需要配置
Integer parallelNumber = 56; // Integer | 用户为作业选择的并发量, 提交Flink自定义作业时需要配置,Spark自定义作业不需要配置
Integer executorNumber = 56; // Integer | Spark作业使用的executor个数, 提交Spark自定义作业时需要配置,Flink自定义作业不需要配置
Integer executorSpu = 56; // Integer | Spark作业每个executor所使用的SPU数, 提交Spark自定义作业时需要配置,Flink自定义作业不需要配置
Boolean logEnabled = true; // Boolean | 是否开启作业日志, true开启, false关闭, 默认false
String obsBucket = "obsBucket_example"; // String | log_enabled==true是, 用户授权保存日志的OBS路径
String smnTopic = "smnTopic_example"; // String | 当作业异常时,向该SMN主题推送告警信息
File jar = new File("/path/to/file.txt"); // File | 用户上传的jar文件, 优先级高于jar_url参数
String jarUrl = "jarUrl_example"; // String | 用户上传的jar包OBS路径
File config = new File("/path/to/file.txt"); // File | 用户上传的配置文件, 优先级高于config_url参数
String configUrl = "configUrl_example"; // String | 用户上传的config包OBS路径
String mainClass = "mainClass_example"; // String | 作业入口类
String args = "args_example"; // String | 作业入口类参数
try {
    JobUpdateResponse result = apiInstance.updateJarJob(xProjectId, jobId, managerSpu, name, desc, clusterId, spuNumber, parallelNumber, executorNumber, executorSpu, logEnabled, obsBucket, smnTopic, jar, jarUrl, config, configUrl, mainClass, args);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling JobApi#updateJarJob");
    System.err.println(e.getResponseBody());
    e.printStackTrace();
}

参数说明

表1 参数说明表

参数名

是否必选

参数类型

说明

xProjectId

String

project id,用于不同project取token。

jobId

Integer

作业ID。

name

String

作业名称。

desc

String

作业描述。

clusterId

Integer

独享集群资源ID,当前用户有该独享资源的使用权限。

spuNumber

Integer

用户为作业选择的SPU数量, 提交Flink自定义作业时需要配置,Spark自定义作业不需要配置。

  • 最小值:2
  • 最大值:400

managerSpu

Integer

用户为作业选择的管理节点SPU数量,Flink自定义作业对应为flink jobmanager数量,Spark自定义作业对应为spark driver数量。

  • 最小值:1
  • 最大值:4

parallelNumber

Integer

用户为作业选择的并发量, 提交Flink自定义作业时需要配置,Spark自定义作业不需要配置。

  • 最小值:1
  • 最大值:2000

executorNumber

Integer

Spark作业使用的executor个数, 提交Spark自定义作业时需要配置,Flink自定义作业不需要配置。

  • 最小值:1
  • 最大值:100

executorSpu

Integer

Spark作业每个executor所使用的SPU数, 提交Spark自定义作业时需要配置,Flink自定义作业不需要配置。

  • 最小值:1
  • 最大值:4

logEnabled

Boolean

是否开启作业日志。默认为false。

  • true:开启。
  • false:关闭。

obsBucket

String

当log_enabled==true时,该参数是用户授权保存日志的OBS路径。

smnTopic

String

当作业异常时,向该SMN主题推送告警信息。

jar

File

用户上传的jar文件,优先级高于jar_url参数。

jarUrl

String

用户上传的jar包OBS路径。

config

File

用户上传的配置文件, 优先级高于config_url参数。

configUrl

String

用户上传的config包OBS路径。

mainClass

String

作业入口类。

args

String

作业入口类参数。

restartWhenException

Boolean

是否开启异常重启功能,默认值为“false”。

tags

String

作业标签。

sysEnterpriseProjectId

String

作业所属的企业项目id。

表2 JobUpdateResponse内的参数说明

参数名

是否必选

参数类型

说明

messageId

String

消息类型ID。

message

String

消息内容。

currentTime

Long

当前时间, 毫秒数。

payload

-

参数类型说明请参见表3

表3 JobUpdateTime内的参数说明

参数名

是否必选

参数类型

说明

updateTime

Integer

作业更新时间,毫秒数。

分享:

    相关文档

    相关产品

文档是否有解决您的问题?

提交成功!

非常感谢您的反馈,我们会继续努力做到更好!

反馈提交失败,请稍后再试!

*必选

请至少选择或填写一项反馈信息

字符长度不能超过200

提交反馈 取消

如您有其它疑问,您也可以通过华为云社区问答频道来与我们联系探讨

智能客服提问云社区提问