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

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

最終更新日:May 23, 2026

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

3 min

-

local-time-zone

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

任意

STRING

システムタイムゾーン

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

user-defined-function

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

任意

LIST

-

詳細については、「ユーザー定義関数」をご参照ください。

transform.allow.trimming.pk-columns

変換ルールでアップストリームのプライマリキー制約を削減することを許可するかどうか。

任意

BOOLEAN

false

アップストリームのプライマリキー制約を削除すると、複数のデータエントリが統合され、データ損失が発生する可能性があります。この設定を使用する前に、新しいプライマリキー (定義されている場合) の一意性を確認してください。

transform.decimal.precision.mode

変換モジュールで使用される 10 進数の最大精度。

任意

STRING

UP_TO_19

有効な値:

  • UP_TO_19:式によって返される Decimal 型の最大精度は 19 です。これは VVR 11.6 以前のデフォルトの動作です。

  • UP_TO_38:式によって返される Decimal 型の最大精度は 38 です。

説明

VVR 11.7 以降でのみサポートされています。