Flink CDC Pipeline模組 - Realtime Compute for Apache Flink

本文向您介紹Flink CDC資料攝入作業支援的全域配置項。您可以在pipeline模組中配置以下選項。

您可以在Flink CDC資料攝入作業的 pipeline模組中配置以下選項，僅對該作業生效。

參數	說明	是否必填	資料類型	預設值	備忘
name	Flink CDC資料攝入作業名稱。	否	STRING	Flink CDC Pipeline Job	無。
schema.change.behavior	Schema變更行為配置。	否	STRING	LENIENT	可配置的值如下，詳見表結構變更同步配置。 `LENIENT`（預設值） `EXCEPTION` `EVOLVE` `TRY_EVOLVE` `IGNORE`
schema-operator.rpc-timeout	Schema變更逾時時間。	否	DURATION	3min	表結構變更協調過程的逾時時間。
local-time-zone	作業執行的本地時區。	否	STRING	系統時區	時區配置會影響Transform模組運算邏輯。
user-defined-function	作業中註冊的UDF函數。	否	LIST	無	在此處註冊自訂函數。詳見自訂函數。
transform.allow.trimming.pk-columns	是否允許Transform規則減少上遊的主鍵約束。	否	BOOLEAN	false	開啟此選項後，允許Transform規則刪除來自上遊的主鍵約束。重要減少上遊的主鍵約束可能導致多條資料被合并，導致資料丟失。需要確保設定的新主鍵（如果存在）也具備唯一性。
transform.decimal.precision.mode	控制 Transform 模組使用的 Decimal 精度上限。	否	STRING	UP_TO_19	目前可選的取值包括： UP_TO_19：運算式的返回 Decimal 類型最高精度為 19。這是 VVR 11.6 及更早版本的預設行為。 UP_TO_38：運算式的返回 Decimal 類型最高精度為 38。說明僅 VVR 11.7 及更高版本支援。