使用說明

操作步驟

1. 登錄Flink全托管控制臺，新建作業(yè)。

   1. 登錄實時計算控制臺。

   2. 單擊目標工作空間操作列下的控制臺。

   3. 在數據開發(fā) > ETL頁面，單擊新建。

   4. 單擊空白的流作業(yè)草稿。

      Flink全托管為您提供了豐富的SQL代碼模板和數據同步模板，每種模板都為您提供了使用場景、代碼示例和使用指導。您也可以直接單擊對應的模板進行使用，快速實現您的業(yè)務邏輯，詳情請參見代碼模板和數據同步模板。

   5. 單擊下一步。

   6. 在新建作業(yè)草稿對話框，填寫作業(yè)配置信息。

      作業(yè)參數	說明
      文件名稱	作業(yè)的名稱。 說明 作業(yè)名稱在當前項目中必須保持唯一。
      存儲位置	指定該作業(yè)的存儲位置。 您還可以在現有文件夾右側，單擊圖標，新建子文件夾。
      引擎版本	當前作業(yè)使用的Flink的引擎版本。引擎版本號含義、版本對應關系和生命周期重要時間點詳情請參見引擎版本介紹。

   7. 單擊創(chuàng)建。

2. 編寫DDL和DML代碼。

   說明

   依托于元數據管理能力，您能夠在不同的作業(yè)中重復利用創(chuàng)建的表結構。在使用Flink開發(fā)控制臺編輯SQL作業(yè)時，只需要輸入部分字符，系統(tǒng)即可自動補全字段和表名稱。

   代碼示例如下。

   --創(chuàng)建源表datagen_source。
   CREATE TEMPORARY TABLE datagen_source(
     name VARCHAR
   ) WITH (
     'connector' = 'datagen'
   );
   
   --創(chuàng)建結果表blackhole_sink。
   CREATE TEMPORARY TABLE blackhole_sink(
     name  VARCHAR
   ) WITH (
     'connector' = 'blackhole'
   );
   
   --將源表數據插入到結果表。
   INSERT INTO blackhole_sink
   SELECT
     name
   from datagen_source;

   1. 在SQL編輯區(qū)域右側頁簽，查看或者填寫配置信息。

      頁簽名稱	配置說明
      更多配置	引擎版本：引擎版本詳情請參見引擎版本介紹和生命周期策略。建議您使用推薦版本或穩(wěn)定版本，引擎版本標記含義詳情如下： 推薦版本（Recommend）：當前最新大版本下的最新小版本。 穩(wěn)定版本（Stable）：還在產品服務期內的大版本下最新的小版本，已修復歷史版本缺陷。 普通版本（Normal）：還在產品服務期內的其他小版本。 EOS版本（Deprecated）：超過產品服務期限的版本。 附加依賴文件：作業(yè)中需要使用到的附加依賴，例如臨時函數等。
      代碼結構	數據流向圖：您可以通過數據流向圖快速查看出數據的流向。 樹狀結構圖：您可以通過樹狀結構圖快速查看出數據的來源。
      版本信息	您可以在此處查看作業(yè)版本信息，操作列下的功能詳情請參見管理作業(yè)版本。

3. 單擊保存。

4. 單擊深度檢查。

   深度檢查能夠檢查作業(yè)的SQL語義、網絡連通性以及作業(yè)使用的表的元數據信息。同時，您可以單擊結果區(qū)域的SQL優(yōu)化，展開查看SQL風險問題提示以及對應的SQL優(yōu)化建議。

5. 可選：單擊調試。

   您可以使用作業(yè)調試功能模擬作業(yè)運行、檢查輸出結果，驗證SELECT或INSERT業(yè)務邏輯的正確性，提升開發(fā)效率，降低數據質量風險。詳情請參見作業(yè)調試。

6. 單擊部署。

   完成作業(yè)開發(fā)和深度檢查后，即可部署作業(yè)，將數據發(fā)布至生產環(huán)境。部署后，您可以在運維中心 > 作業(yè)運維頁面啟動作業(yè)至運行階段，詳情請參見作業(yè)啟動。