数据湖探索 DLI-Flink作业相关:新建SQL作业

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

数据湖探索 DLI

新建SQL作业

DLI 提供新建Flink SQL作业的接口。您可以使用该接口新建Flink SQL作业并提交到DLI，示例代码如下：

  
       private static void createSQLJob(DLIClient client) throws DLIException {    SubmitFlinkSqlJobRequest body = new SubmitFlinkSqlJobRequest();    body.name("job-name");    body.runMode(SubmitFlinkSqlJobRequest.RunModeEnum.SHARED_CLUSTER);    body.checkpointEnabled(false);    body.checkpointMode(1);    body.jobType(SubmitFlinkSqlJobRequest.JobTypeEnum.JOB);    JobStatusResponse result = client.submitFlinkSqlJob(body);    System.out.println(result);}