Ververica Flink實時引擎

開發環境啟動實時實例

• 啟動計算實時實例

  1. 在測試實例參數配置對話框中，配置測試實例參數的具體值。

     參數	描述
     指定來源表讀取數據時點	設置讀取數據時點。設置指定開始時間會讓所有支持startTime的來源表均從該時刻開始讀取數據。 重要 目前支持Log Service CDC、Kafka CDC、MySQL CDC、MongoDB CDC、OceanBase CDC指定來源表讀取數據時點。 SQL作業中的代碼參數配置將優先于此指定的開始時間。
     測試方式	實時任務為FLINK測試方式包括打印日志和寫測試表： 選擇打印日志后，測試結果寫入日志，不生成測試表。 選擇寫測試表，則測試結果不會寫入日志，但會生成對應的測試表。 重要 需要您確保物理數據庫（如MySQL等）上已有該測試表，否則會導致啟動實時實例的運行失敗。
     輸入表	無需配置，為您展示當前實時實例的輸入表名稱。
     業務日期	支持通過配置業務日期對時間變量賦值，時間類型的變量基于業務日期計算。默認為當天。

     測試實例時系統讀取開發表還是生產環境的測試元表，根據元表的配置決定。查看元表配置，請參見創建及管理元表。

     

     • 元表的開發環境測試時讀取參數選中開發表。

       • 任務中使用的是Project_Name_dev.元表名，則讀取開發環境測試元表。

       • 任務中使用的是Project_Name.元表名，則讀取生產元表。如果您沒有生產環境測試元表權限，則會報錯。如何申請生產環境測試元表權限，請參見申請、續期和交還表權限。

       • 任務中使用的是${Project_Name}.元表名或元表名，則讀取開發環境測試元表。

     • 元表的開發環境測試時讀取參數選中生產表。

       • 任務中使用的是Project_Name_dev.元表名，則讀取開發環境測試元表。

       • 任務中使用的是Project_Name.元表名，則讀取生產環境測試元表。

       • 任務中使用的是${Project_Name}.元表名或元表名，則讀取生產環境測試元表。

     • 元表的開發環境測試時寫入參數選擇為其他測試表。

       • 任務中使用的是Project_Name_dev.元表名，則寫入開發測試元表。

       • 任務中使用的是Project_Name.元表名，則寫入生產環境測試元表。如果您沒有生產環境測試元表權限，則會報錯。如何申請生產環境測試元表權限，請參見申請、續期和交還表權限。

       • 任務中使用的是${Project_Name}.元表名或元表名，則寫入開發環境測試元表。

  2. 單擊啟動。

• 啟動實時集成實例

  1. 在啟動實時實例對話框中，配置啟動信息。

     參數	描述
     啟動實例	無需配置，為您展示啟動的實例名稱。
     啟動方式	支持無狀態啟動和從有效狀態啟動。 無狀態啟動：不帶任何初始狀態啟動。無狀態啟動時可指定來源表讀取數據時點 。設置指定開始時間會讓所有支持startTime的來源表均從該時刻開始讀取數據。 重要 目前支持Log Service CDC、Kafka CDC、MySQL CDC、MongoDB CDC、OceanBase CDC指定來源表讀取數據時點。 默認值為上次結束的數據時點。 SQL作業中的代碼參數配置將優先于此指定的開始時間。 從有效狀態啟動：從已存在的有效狀態啟動。支持下拉選擇Checkpoint或Savepoint，僅支持選擇最近8個有效狀態（Checkpoint或Savepoint）。默認為最新狀態啟動。 說明 實時實例不存在最近的有效狀態時，不支持從有效狀態啟動。

  2. 單擊啟動。

生產環境啟動實時實例

1. 在啟動實時實例對話框中，配置啟動信息。

   參數	描述
   啟動實例	無需配置，為您展示啟動的實例名稱。
   啟動方式	支持無狀態啟動和從有效狀態啟動。 無狀態啟動：不帶任何初始狀態啟動。無狀態啟動時可指定來源表讀取數據時點。設置指定開始時間會讓所有支持startTime的來源表均從該時刻開始讀取數據。 重要 目前支持Log Service CDC、Kafka CDC、MySQL CDC、MongoDB CDC、OceanBase CDC指定來源表讀取數據時點。 SQL作業中的代碼參數配置將優先于此指定的開始時間。 從有效狀態啟動：從已存在的有效狀態啟動。支持下拉選擇Checkpoint或Savepoint，僅支持選擇最近8個有效狀態（Checkpoint或Savepoint）。默認為最新狀態啟動。 說明 實時實例不存在最近的有效狀態時，不支持從有效狀態啟動。
   業務日期	支持通過配置業務日期對時間變量賦值，時間類型的變量基于業務日期計算。默認為當天。 說明 實時集成任務不支持業務日期配置。

3. 單擊啟動。

Alibaba Blink實時引擎

開發環境啟動實時實例

1. 在測試實例參數配置對話框中，配置測試實例參數的具體值。

   參數	描述
   讀取數據時點	設置來源數據的讀取消費時間。
   測試方式	實時任務為FLINK測試方式包括打印日志和寫測試表： 選擇打印日志后，測試結果寫入日志，不生成測試表。 選擇寫測試表，則測試結果不寫入日志，但會生成對應測試表。 重要 需要您確保物理存儲引擎（例如HBase、Kafka等）上已有該測試表，否則會導致啟動實時實例的運行失敗。
   輸入表	無需配置，為您展示當前實時實例的輸入表名稱。
   業務日期	支持通過配置業務日期對時間變量賦值，時間類型的變量基于業務日期計算。默認為當天。

   測試實例時系統讀取開發表還是生產環境的測試元表，根據元表的配置決定。查看元表配置，請參見創建及管理元表。

   

   • 元表的開發環境測試時讀取參數選中開發表。

     • 任務中使用的是Project_Name_dev.元表名，則讀取開發環境測試元表。

     • 任務中使用的是Project_Name.元表名，則讀取生產元表。如果您沒有生產環境測試元表權限，則會報錯。如何申請生產環境測試元表權限，請參見申請、續期和交還表權限。

     • 任務中使用的是${Project_Name}.元表名或元表名，則讀取開發環境測試元表。

   • 元表的開發環境測試時讀取參數選中生產表。

     • 任務中使用的是Project_Name_dev.元表名，則讀取開發環境測試元表。

     • 任務中使用的是Project_Name.元表名，則讀取生產環境測試元表。

     • 任務中使用的是${Project_Name}.元表名或元表名，則讀取生產環境測試元表。

   • 元表的開發環境測試時寫入參數選擇為其他測試表。

     • 任務中使用的是Project_Name_dev.元表名，則寫入開發測試元表。

     • 任務中使用的是Project_Name.元表名，則寫入生產環境測試元表。如果您沒有生產環境測試元表權限，則會報錯。如何申請生產環境測試元表權限，請參見申請、續期和交還表權限。

     • 任務中使用的是${Project_Name}.元表名或元表名，則寫入開發環境測試元表。

2. 單擊啟動。

生產環境啟動實時實例

1. 在啟動實時實例對話框中，配置啟動信息。

   參數	描述
   讀取數據時點	設置來源數據的讀取消費時間。
   業務日期	支持通過配置業務日期對時間變量賦值，時間類型的變量基于業務日期計算。默認為當天。

3. 單擊啟動。