Realtime Compute for Apache Flink:Modul pipeline Flink CDC

Parameter

Deskripsi

Wajib

Tipe data

Nilai default

Catatan

name

Nama pekerjaan ingesti data Flink CDC.

Tidak

STRING

Flink CDC Pipeline Job

-

schema.change.behavior

Strategi untuk menangani perubahan skema.

Tidak

STRING

LENIENT

Nilai yang valid tercantum di bawah ini. Untuk informasi selengkapnya, lihat Konfigurasi evolusi skema.

• LENIENT (default)

• EXCEPTION

• EVOLVE

• TRY_EVOLVE

• IGNORE

schema-operator.rpc-timeout

Periode timeout untuk SchemaOperator menunggu penyelesaian penerapan event perubahan skema downstream.

Tidak

DURATION

3min

-

local-time-zone

Zona waktu lokal untuk eksekusi pekerjaan.

Tidak

STRING

Zona waktu sistem

Pengaturan ini memengaruhi perhitungan yang berkaitan dengan waktu dalam modul transform.

user-defined-function

Fungsi user-defined (UDF) yang akan didaftarkan untuk pekerjaan.

Tidak

LIST

-

Untuk informasi selengkapnya, lihat User-defined functions.

transform.allow.trimming.pk-columns

Mengizinkan aturan transform untuk mengurangi batasan primary key upstream

Tidak

BOOLEAN

false

Menghapus batasan PK upstream dapat menyebabkan beberapa entri data digabung, sehingga berpotensi menyebabkan kehilangan data. Sebelum menggunakan pengaturan ini, pastikan keunikan PK baru (jika didefinisikan).

transform.decimal.precision.mode

Menentukan presisi Decimal maksimum yang digunakan oleh modul Transform.

Tidak

STRING

UP_TO_19

Nilai yang valid:

• UP_TO_19: Presisi maksimum tipe Decimal yang dikembalikan oleh ekspresi adalah 19. Ini merupakan perilaku default pada VVR 11.6 dan versi sebelumnya.

• UP_TO_38: Presisi maksimum tipe Decimal yang dikembalikan oleh ekspresi adalah 38.