Modul pipeline Flink CDC - Realtime Compute for Apache Flink

Modul pipeline berisi konfigurasi global untuk pekerjaan data ingestion Flink CDC.

Parameter

Parameter pipeline berikut hanya berlaku untuk pekerjaan data ingestion Flink CDC saat ini.

Parameter	Description	Required	Data type	Default value	Note
`name`	Nama pekerjaan data ingestion Flink CDC.	No	STRING	Flink CDC Pipeline Job	-
`schema.change.behavior`	Strategi untuk menangani perubahan skema.	No	STRING	`LENIENT`	Nilai yang valid tercantum di bawah ini. Untuk informasi selengkapnya, lihat Schema evolution configurations. `LENIENT` (default) `EXCEPTION` `EVOLVE` `TRY_EVOLVE` `IGNORE`
`schema-operator.rpc-timeout`	Periode timeout untuk SchemaOperator menunggu penyelesaian penerapan event perubahan skema downstream.	No	DURATION	3min	Periode timeout untuk proses koordinasi perubahan skema.
`local-time-zone`	Zona waktu lokal untuk eksekusi pekerjaan.	No	STRING	System time zone	Pengaturan ini memengaruhi perhitungan yang berkaitan dengan waktu dalam modul `transform`.
`user-defined-function`	Fungsi user-defined (UDF) yang akan didaftarkan untuk pekerjaan.	No	LIST	-	Untuk informasi selengkapnya, lihat User-defined functions.
transform.allow.trimming.pk-columns	Mengizinkan aturan transform untuk mengurangi batasan primary key upstream	No	BOOLEAN	false	Menghapus batasan PK upstream dapat menyebabkan beberapa entri data digabung, berpotensi mengakibatkan 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.	No	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. Catatan Hanya didukung pada VVR 11.7 dan versi setelahnya.
sink.partitioning.strategy	Menentukan strategi partisi yang mendistribusikan event perubahan data ke subtask downstream sink.	No	STRING	SINK_DEFINED	Nilai yang valid: SINK_DEFINED: Menggunakan strategi partisi yang ditentukan oleh sink. Ini merupakan nilai default. Sink Paimon, Fluss, dan MaxCompute hanya mendukung SINK_DEFINED. PRIMARY_KEY: Mempartisi event berdasarkan ID tabel dan nilai primary key. Event dengan primary key yang sama diarahkan ke subtask yang sama. TABLE_ID: Mempartisi event berdasarkan ID tabel. Semua event dari tabel yang sama diarahkan ke subtask yang sama. Catatan Hanya didukung pada VVR 11.8 dan versi setelahnya.
transform.async-execution.enabled	Menentukan apakah akan mengaktifkan eksekusi asinkron terurut untuk Post-Transform (pratinjau publik).	No	BOOLEAN	false	Fitur eksperimental. Jika parameter ini diaktifkan, perhitungan Transform dijalankan secara asinkron dalam kolam thread sambil mempertahankan urutan output event. Opsi ini cocok untuk Transform yang mencakup pemanggilan UDF atau model AI dengan latensi tinggi. Catatan Hanya didukung pada Ververica Runtime (VVR) 11.9 dan versi setelahnya. Penting State Checkpoint dan Savepoint yang dihasilkan saat parameter ini diaktifkan tidak kompatibel dengan state yang dihasilkan saat parameter ini dinonaktifkan. Penyesuaian paralelisme secara dinamis tidak didukung setelah parameter ini diaktifkan.
transform.async-execution.timeout	Periode timeout untuk memproses satu event Post-Transform secara asinkron (pratinjau publik).	No	DURATION	5min	Fitur eksperimental. Parameter ini hanya berlaku ketika Transform asinkron diaktifkan. Nilainya harus lebih besar dari 0. Catatan Hanya didukung pada Ververica Runtime (VVR) 11.9 dan versi setelahnya.
transform.async-execution.capacity	Jumlah maksimum event yang sedang diproses yang dapat ditangani secara konkuren oleh setiap subtask Post-Transform asinkron (pratinjau publik).	No	INTEGER	100	Fitur eksperimental. Parameter ini hanya berlaku ketika Transform asinkron diaktifkan. Nilainya harus lebih besar dari 0. Nilai yang lebih besar umumnya memberikan konkurensi lebih tinggi tetapi mengonsumsi lebih banyak memori. Catatan Hanya didukung pada Ververica Runtime (VVR) 11.9 dan versi setelahnya.
transform.async-execution.worker-threads	Jumlah thread pekerja yang digunakan oleh setiap subtask Post-Transform asinkron (pratinjau publik).	No	INTEGER	16	Fitur eksperimental. Parameter ini hanya berlaku ketika Transform asinkron diaktifkan. Nilainya harus lebih besar dari 0. Jumlah total thread meningkat seiring dengan peningkatan paralelisme Transform. Catatan Hanya didukung pada Ververica Runtime (VVR) 11.9 dan versi setelahnya.