Dataphin：步驟四：開發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. 單擊確定並提交。