Halaman ini mencakup perubahan yang diterapkan pada Realtime Compute for Apache Flink dalam rilis 4 Agustus 2021, termasuk Ververica Platform (VVP) dan Ververica Runtime (VVR) 4.0.8.
Aksi yang diperlukan sebelum upgrade
Baca bagian ini sebelum melakukan upgrade. Perubahan berikut memerlukan tindakan guna mencegah kegagalan pekerjaan atau kehilangan data.
Menghentikan pekerjaan kini akan menghapus semua checkpoint-nya. Jika Anda perlu memulihkan status pekerjaan setelah dihentikan, gunakan salah satu pendekatan berikut sebagai gantinya:
Suspend and resume — menangguhkan pekerjaan akan mempertahankan status sehingga Anda dapat melanjutkannya dari titik terakhir.
Restore from a savepoint — hentikan pekerjaan, lalu pulihkan dari savepoint yang telah dibuat sebelumnya.
Diperlukan migrasi versi engine untuk pekerjaan yang menggunakan Flink 1.11 atau lebih lama.
Mulai dari VVR 3.0.3, VVP mendukung menjalankan pekerjaan SQL dengan berbagai versi engine secara bersamaan. Format versi engine juga telah berubah menjadi vvr-<VVR version>-flink-<Flink version>.
Lakukan tindakan berikut berdasarkan versi engine saat ini:
| Versi engine saat ini | Aksi yang diperlukan |
|---|---|
| Flink 1.12 | Hentikan dan restart pekerjaan. VVP secara otomatis memperbarui versi engine menjadi vvr-3.0.3-flink-1.12. |
| Flink 1.11 atau Flink 1.10 | Perbarui secara manual versi engine menjadi vvr-3.0.3-flink-1.12 atau vvr-4.0.8-flink-1.13 sebelum melakukan restart. Melakukan restart tanpa memperbarui akan menyebabkan error timeout. |
Fitur baru
Pekerjaan SQL
Konfigurasi resource tingkat granularitas halus — konfigurasikan jumlah core CPU dan ukuran memori untuk shared slot dalam pekerjaan SQL. Hal ini memungkinkan Anda menyesuaikan alokasi resource per pekerjaan, bukan menerapkan pengaturan tunggal di seluruh kluster. Lihat Configure a deployment.
Manajemen versi — menerbitkan pekerjaan kini menghasilkan versi pengembangan. Bandingkan versi secara berdampingan dan kembalikan ke versi historis apa pun jika penerbitan baru menyebabkan masalah. Lihat Manage job versions.
Hologres catalog — buat Hologres catalog di Konsol pengembangan untuk mengakses tabel Hologres dan membaca metadata Hologres tanpa keluar dari Realtime Compute for Apache Flink. Lihat Manage Hologres catalogs.
Pekerjaan SQL multi-versi — terbitkan pekerjaan SQL menggunakan berbagai versi engine dalam ruang kerja yang sama. Versi yang didukung:
vvr-3.0.3-flink-1.12danvvr-4.0.8-flink-1.13.
Connectors
MySQL CDC connector — mendukung pembacaan data penuh dalam beberapa thread paralel, algoritma tanpa lock, dan unggah yang dapat dilanjutkan.
AnalyticDB for MySQL V3.0 connector — kini mendukung semantik
ON DUPLICATE KEY UPDATE.ApsaraDB RDS for MySQL connector — versi driver Java Database Connectivity (JDBC) dapat diperbarui untuk mendukung lebih banyak set karakter.
Monitoring dan alerting
Frekuensi alert — konfigurasikan seberapa sering alert dipicu untuk mengurangi kebisingan dalam skenario frekuensi tinggi.
Alert webhook — kirim alert langsung ke endpoint webhook untuk integrasi dengan sistem notifikasi eksternal.
Penyempurnaan
Unggah paket JAR lebih cepat — metode unggah telah dioptimalkan, sehingga mengurangi waktu yang diperlukan untuk mengunggah paket JAR.
Nama pekerjaan dalam log — nama pekerjaan kini disertakan dalam log yang diunduh ke Log Service, sehingga lebih mudah mengidentifikasi pekerjaan mana yang menghasilkan entri log tertentu.
Perbaikan bug
Memperbaiki masalah di mana metrik
currentEmitEventTimeLagmenampilkanLog.MAXketika beberapa partisi dalam tabel Kafka tidak memiliki data.