数据湖探索 DLI-Flink作业相关:更新自定义作业

时间:2024-07-05 17:23:48

更新自定义作业

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

1
2
3
4
5
6
   private static void updateFlinkJob(DLIClient client) throws DLIException {
        UpdateFlinkJarJobRequest body = new UpdateFlinkJarJobRequest();
        body.name("update-job");
        JobUpdateResponse result = client.updateFlinkJarJob(body,202L);
        System.out.println(result);
    }
support.huaweicloud.com/sdkreference-dli/dli_04_0085.html