步驟一：新建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. 單擊確定并提交。