全部產品
Search
文件中心

Realtime Compute for Apache Flink:Flink CDC Pipeline模組

更新時間:Aug 08, 2025

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

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

在此處註冊自訂函數。詳見自訂函數