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

时间：2025-02-12 14:54:10

数据湖探索 DLI

新建自定义作业

DLI 提供新建Flink自定义作业的接口。您可以使用该接口创建一个用户自定义作业，目前支持jar格式，运行在独享队列中。示例代码如下：

  
       private static void createFlinkJob(DLIClient client) throws DLIException {     CreateFlinkJarJobRequest body = new CreateFlinkJarJobRequest();     body.name("jar-job");     body.cuNumber(2);     body.managerCuNumber(1);     body.parallelNumber(1);     body.entrypoint("dli/WindowJoin.jar");     JobStatusResponse result = client.createFlinkJarJob(body);     System.out.println(result); }