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

更新SQL作业

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

样例代码

用户可以使用该接口更新流式SQL作业,流式SQL的语法扩展了Apache Flink SQL,具体详情请参考《实时流计算服务SQL语法参考》文档。示例代码如下:

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
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.
UpdateSqlJobRequest body = new UpdateSqlJobRequest(); // UpdateSqlJobRequest | 提交修改SQL作业请求
try {
    JobUpdateResponse result = apiInstance.updateSqlJob(xProjectId, body);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling JobApi#updateSqlJob");
    System.err.println(e.getResponseBody());
    e.printStackTrace();
}

参数说明

表1 参数说明表

参数名

是否必选

参数类型

说明

xProjectId

String

project id,用于不同project取token。

body

-

提交修改SQL作业请求。参数类型说明请参见表2

表2 UpdateSqlJobRequest内的参数说明

参数名

是否必选

参数类型

说明

jobId

Integer

作业ID。

name

String

作业名称。

desc

String

作业描述。

clusterId

Integer

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

sqlBody

String

Stream SQL语句,至少包含source,query,sink三个部分。

runMode

RunModeEnum

作业运行模式,包括以下三种模式:

  • shared_cluster:共享
  • exclusive_cluster:独享
  • edge_node:边缘节点

spuNumber

Integer

用户为作业选择的SPU数量。

  • 最小值:2
  • 最大值:400
  • 默认值:5

parallelNumber

Integer

用户设置的作业并行数。

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

checkpointEnabled

Boolean

是否开启作业自动快照功能。默认值为“true”。

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

checkpointMode

String

快照模式有两种可选:

  • exactly_once
  • at_least_once

checkpointInterval

Integer

快照时间间隔,单位为秒。默认值为“10”。

obsBucket

String

当checkpoint_enabled==true时,该参数是用户授权保存快照的OBS路径。

logEnabled

Boolean

是否开启作业的日志上传到用户的OBS功能。默认值为“false”。

smnTopic

String

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

restartWhenException

Boolean

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

idleStateRetention

Integer

空闲状态最长保留时间,超过该时间没有进行更新的中间状态会被删除,单位为秒。默认值为“3600”。

edgeGroupIds

String

边缘计算组ID列表,多个ID以逗号分隔。

tags

String

作业标签。

sysEnterpriseProjectId

String

作业所属的企业项目ID。

udfJarUrl

String

sql作业udf jar所在的obs地址。

dirtyDataStrategy

String

作业脏数据策略。

  • “2:obs-wan-wulan3/jobs”:保存
  • “1”:抛出异常
  • “0”:忽略
表3 JobUpdateResponse内的参数说明

参数名

是否必选

参数类型

说明

messageId

String

消息类型ID。

message

String

消息内容。

currentTime

Long

当前时间, 毫秒数。

payload

-

参数类型说明请参见表3

表4 JobUpdateTime内的参数说明

参数名

是否必选

参数类型

说明

updateTime

Integer

作业更新时间,毫秒数。

分享:

    相关文档

    相关产品

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

提交成功!

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

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

*必选

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

字符长度不能超过200

提交反馈 取消

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

智能客服提问云社区提问