步骤四：开发FLINK_SQL实时任务

步骤一：新建FLINK_SQL任务

1. 在Dataphin首页，单击顶部菜单栏研发。

2. 按照下图操作指引，进入新建FLINK_SQL任务对话框。

   

3. 在新建FLINK_SQL任务对话框，配置参数。

   参数	说明
   任务名称	填写flink_dataphin。
   生产环境集群	选择FLINK_SQL任务所在集群。
   引擎版本	选择生vvr-8.0.1-flink-1.17版本。
   使用模板	默认不开启。
   存储目录	默认选择为代码管理。
   描述	填写对FLINK_SQL任务的简单描述，例如计算单品的销售总数。

4. 单击确定。

步骤二：开发与预编译FLINK_SQL任务代码

1. 在FLINK_SQL任务代码页面，编写任务的代码。 代码如下：

   INSERT INTO ads_gross
   SELECT
            sku_type as prod_code
           ,sum(sku_quantity) as sale_num
   FROM    oms_orders
   GROUP BY  sku_type;

2. 单击页面左上方的按钮，校验代码任务的语法及权限问题。

   说明

   1. 预编译成功，页面上方出现弹窗。

   2. 预编译失败，页面上方出现弹窗，单击页面底部Console，查看预编译失败日志。

步骤三：提交FLINK_SQL任务

1. 单击页面左上方的按钮，并在提交备注对话框中填写备注信息。

2. 单击确定并提交。