Rilis ini didasarkan pada Ververica Runtime (VVR) 6.0.5 dan Apache Flink 1.15.3. Semua cacat dalam Apache Flink 1.15.3 telah diperbaiki dalam rilis ini.
Apa yang ada dalam rilis ini:
Konektor baru: Konektor StarRocks kini secara resmi diluncurkan untuk tabel sumber maupun tabel hasil.
Peningkatan SQL: Pemrosesan Peristiwa Kompleks (CEP) Flink SQL mendukung pola kelompok dan pola NO SKIP.
Perbaikan CDC: Pemetaan tipe data dan sinkronisasi metadata
op_tskini didukung dalam ingesti data real-time.Konektor Log Service: Opsi baru untuk konfigurasi bucket Logstore dan konsumsi log berbasis checkpoint kelompok konsumen.
Perbaikan bug: Tiga masalah telah diselesaikan pada konektor Kafka, Flink CDC dengan JDBC, dan Codegen.
Fitur baru
| Fitur | Deskripsi | Referensi |
|---|---|---|
| Pemetaan tipe data dalam konektor Flink CDC | Saat menggunakan pernyataan CREATE DATABASE AS atau CREATE TABLE AS untuk mengingesti data ke data lake atau gudang data, kolom hulu dan hilir dapat memiliki tipe data yang berbeda namun kompatibel. Hal ini mencegah error ketidaksesuaian tipe yang tidak perlu. Batasan: Penyimpanan data hilir harus berupa Hologres. | Kelola katalog Hologres, Pernyataan CREATE TABLE AS |
| Pola grup dan pola NO SKIP dalam Flink SQL CEP | Pemrosesan Peristiwa Kompleks (CEP) Flink SQL kini mendukung pola kelompok (seperti A(B C)+) dan pola NO SKIP (seperti A B{4,10}?), memungkinkan pencocokan event yang lebih ekspresif di berbagai elemen. | Pernyataan CEP |
| Konfigurasi bucket dan checkpoint kelompok konsumen dalam konektor Log Service | Untuk Logstore dengan lebih dari 64 shard, tentukan jumlah bucket secara langsung dalam konfigurasi konektor. Konektor juga dapat melanjutkan konsumsi log dari checkpoint yang disimpan dalam kelompok konsumen tertentu. | Buat tabel sumber Log Service |
| Konektor StarRocks | Konektor StarRocks kini secara resmi diluncurkan. Gunakan konektor ini untuk membaca data dari tabel sumber StarRocks dan menulis data ke tabel hasil StarRocks. | N/A |
op_ts sinkronisasi metadata dalam CREATE TABLE AS | Saat mengeksekusi pernyataan CREATE TABLE AS, bidang metadata seperti op_ts kini disertakan dalam sinkronisasi. | Kelola katalog MySQL |
Masalah yang diperbaiki
Konektor Kafka: Memperbaiki masalah di mana modifikasi parameter dalam klausa
WITHpada konektor Message Queue for Apache Kafka menyebabkan penerapan gagal saat restart.Flink CDC dengan JDBC: Memperbaiki masalah di mana, saat Flink Change Data Capture (CDC) menggunakan driver Java Database Connectivity (JDBC) untuk membaca data dalam thread asinkron, penyebab error out of memory (OOM) tidak dapat ditampilkan.
Codegen: Memperbaiki masalah di mana error Codegen menyebabkan pesan error
Table program cannot be compiled.muncul.