版本: 0.6

作业开发

说明

SQL 编辑器编辑的 FlinkSQL 作业，当前仅支持 Flink1.11、Flink1.12、Flink1.13、Flink1.14 版本的语法。

FlinkSQL 操作步骤

1.进入 Dinky 的 Data Studio

2.在左侧菜单栏，右键目录

3.新建目录或作业

4.在新建文件的对话框，填写作业信息

参数	说明	备注
作业名称	作业名称在当前项目中必须保持唯一
作业类型	流作业和批作业均支持以下作业类型： FlinkSQL：支持SET、DML、DDL语法 FlinkSQLEnv：支持SET、DDL语法	FlinkSQLEnv 场景适用于所有作业的SET、DDL语法统一管理的场景，当前FlinkSQLEnv 在SQL编辑器的语句限制在1000行以内

5.在作业开发 SQL 编辑器，编写 DDL 和 DML 代码

示例代码如下：

--创建源表datagen_source
CREATE TABLE datagen_source(
  id  BIGINT,
  name STRING
) WITH (
  'connector' = 'datagen'
);
--创建结果表blackhole_sink
CREATE  TABLE blackhole_sink(
   id  BIGINT,
   name STRING
) WITH (
  'connector' = 'blackhole'
);
--将源表数据插入到结果表
INSERT INTO blackhole_sink
SELECT
   id  ,
   name 
from datagen_source;

新建作业如下图：

6.在作业开发页面右侧 执行配置，填写配置信息

类型	配置项	备注
作业配置	执行模式	区别详见用户手册数据开发中的作业概述
作业配置	集群实例	Standalone 和 Session 执行模式需要选择集群实例，详见集群实例管理
作业配置	集群配置	Per-Job 和 Application 执行模式需要选择集群配置，详见集群配置管理
作业配置	FlinkSQL 环境	选择已创建的 FlinkSQLEnv，如果没有则不选
作业配置	任务并行度	指定作业级任务并行度，默认为 1
作业配置	Insert 语句集	默认禁用，开启后将 SQL编辑器中编写的多个 Insert 语句合并为一个 JobGraph 进行提交
作业配置	全局变量	默认禁用，开启后可以使用数据源连接配置变量、自定义变量等
作业配置	批模式	默认禁用，开启后启用 Batch Mode
作业配置	SavePoint 策略	默认禁用，策略包括: 最近一次最早一次指定一次
作业配置	报警组	报警组配置详见报警管理
作业配置	其他配置	其他的 Flink 作业配置，具体可选参数，请参考 Flink 官网

作业配置如下图：

job_config

注意事项

请及时手动保存作业信息，以免丢失

FlinkSQL 操作步骤​

FlinkSQL 操作步骤