すべてのプロダクト
Search
ドキュメントセンター

Realtime Compute for Apache Flink:Flink CDC パイプラインモジュール

最終更新日:Oct 18, 2025

pipeline モジュールには、Flink CDC データインジェスチョンジョブのグローバル構成が含まれています。

パラメーター

次の pipeline パラメーターは、現在の Flink CDC データインジェスチョンジョブにのみ適用されます。

パラメーター

説明

必須

データ型

デフォルト値

name

Flink CDC データインジェスチョンジョブの名前。

いいえ

STRING

Flink CDC Pipeline Job

schema.change.behavior

スキーマ変更を処理するストラテジー。

いいえ

STRING

LENIENT

有効な値は以下のとおりです。詳細については、「スキーマエボリューション構成」をご参照ください。

  • LENIENT (デフォルト)

  • EXCEPTION

  • EVOLVE

  • TRY_EVOLVE

  • IGNORE

schema-operator.rpc-timeout

SchemaOperator がダウンストリームのスキーマ変更イベントの適用完了を待つタイムアウト期間。

いいえ

DURATION

3min

local-time-zone

ジョブ実行のローカルタイムゾーン。

いいえ

STRING

システムタイムゾーン

この設定は、transform モジュールでの時間関連の計算に影響します。

user-defined-function

ジョブに登録するユーザー定義関数 (UDF)。

いいえ

LIST

デフォルト値なし

詳細については、「UDF の管理」をご参照ください。