Tingkatkan versi mesin dari suatu penyebaran - Realtime Compute for Apache Flink

Apache Flink adalah salah satu mesin komputasi aliran paling populer yang terus diperbarui secara aktif. Anda dapat meningkatkan versi mesin penyebaran ke versi baru untuk memanfaatkan fitur-fitur terbaru atau yang telah diperbarui. Topik ini menjelaskan cara meningkatkan versi mesin penyebaran Realtime Compute for Apache Flink.

Catatan Penggunaan

Sebelum dirilisnya versi mesin baru Realtime Compute for Apache Flink, berbagai tes kompatibilitas dilakukan. Secara umum, versi minor dari versi utama yang sama kompatibel satu sama lain. Namun, kompatibilitas antar versi utama tidak dijamin. Untuk informasi lebih lanjut, lihat bagian "Versi Mesin dan Arti Setiap Digit dalam Nomor Versi" pada topik Versi Mesin dan bagian "Tabel Kompatibilitas" pada topik Meningkatkan Aplikasi dan Versi Flink.

Jika Anda ingin mengubah versi mesin penyebaran, perhatikan hal-hal berikut:

Jika Anda meningkatkan versi mesin penyebaran ke versi minor terbaru dari versi utama yang sama, seperti dari vvr-4.0.15-flink-1.13 ke vvr-4.0.18-flink-1.13, penyebaran setelah peningkatan akan kompatibel dengan data state sebelum peningkatan dan dapat menggunakan checkpoint atau savepoint yang dihasilkan sebelum peningkatan.
Jika Anda meningkatkan versi mesin penyebaran ke versi utama terbaru, seperti dari vvr-4.0.15-flink-1.13 ke vvr-6.0.2-flink-1.15, penyebaran setelah peningkatan tidak akan kompatibel dengan data state sebelum peningkatan. Anda harus memulai ulang penyebaran tanpa data state.
Versi dependensi Realtime Compute for Apache Flink dalam penyebaran SQL atau DataStream harus sesuai dengan versi Realtime Compute for Apache Flink yang dipilih untuk penyebaran tersebut.
Untuk Apache Flink 1.13.0 dan yang lebih baru, BlinkPlanner digunakan sebagai SQL Planner default. BlinkPlanner disediakan oleh Alibaba Group untuk komunitas Apache Flink. Terdapat perbedaan spesifik antara Apache Flink 1.13.0 dan versi sebelumnya. Untuk informasi lebih lanjut tentang perbedaan tersebut, lihat Pengumuman Rilis Apache Flink 1.13.0. Oleh karena itu, jika Anda memigrasikan data dari penyebaran berbasis versi Apache Flink sebelum 1.13.0 ke penyebaran Realtime Compute for Apache Flink yang menggunakan Ververica Runtime (VVR) 4.0 atau lebih baru berdasarkan Apache Flink 1.13.0, sintaks dan API tertentu mungkin tidak kompatibel dengan sintaks dan API dari komunitas Apache Flink.

Prosedur

Langkah 1: Cadangkan draf dan terapkan draf

Untuk memastikan stabilitas penyebaran, kami sarankan Anda mengkloning draf penyebaran dan meningkatkan versi mesin draf yang dikloning.

SQL

Masuk ke konsol manajemen Realtime Compute for Apache Flink. Temukan ruang kerja yang ingin Anda kelola dan klik Console di kolom Actions.
Cadangkan draf SQL.
1. Di panel navigasi di sebelah kiri, pilih Development > ETL. Pada tab Drafts di halaman yang muncul, klik nama draf yang ingin Anda kelola.
2. Klik Save As di bagian atas draf.
3. Di kotak dialog yang muncul, masukkan nama file untuk parameter Name, tentukan parameter Location, lalu klik Save.
Tingkatkan versi mesin draf baru.
Saat mengubah versi mesin draf baru, kami sarankan Anda memilih versi stabil atau versi yang direkomendasikan. Cacat yang diketahui dan masalah terkait di versi lain telah diperbaiki di versi stabil dan versi yang direkomendasikan. Versi ini menyediakan fitur terbaru dan stabilitas yang lebih tinggi.
1. Di sisi kanan draf baru, klik tab Configurations. Di panel Configurations, pilih versi yang ingin Anda gunakan dari daftar drop-down Engine Version, lalu klik Deploy di pojok kanan atas.
2. Di panel navigasi di sebelah kiri, pilih O&M > Deployments. Pada halaman Deployments, klik nama penyebaran yang ingin Anda kelola. Di bagian Basic dari tab Configuration, periksa apakah versi mesin penyebaran telah berubah.

DataStream

Masuk ke konsol manajemen Realtime Compute for Apache Flink. Temukan ruang kerja yang ingin Anda kelola dan klik Console di kolom Actions.
Cadangkan draf DataStream dan pilih versi mesin baru untuk draf baru.
Saat mengubah versi mesin draf baru, kami sarankan Anda memilih versi stabil atau versi yang direkomendasikan. Cacat yang diketahui dan masalah terkait di versi lain telah diperbaiki di versi stabil dan versi yang direkomendasikan. Versi ini menyediakan fitur terbaru dan stabilitas yang lebih tinggi.
1. Di panel navigasi di sebelah kiri, pilih O&M > Deployments. Pada halaman Deployments, klik nama penyebaran yang ingin Anda kelola.
2. Di pojok kanan atas halaman yang muncul, klik Clone.
3. Masukkan nama baru di bidang Deployment Name, dan pilih versi baru dari daftar drop-down Engine Version.
Klik Deploy.

Langkah 2: Cadangkan status penyebaran

Di panel navigasi di sebelah kiri konsol Realtime Compute for Apache Flink, pilih O&M > Deployments. Pada halaman Deployments, klik nama penyebaran yang ingin Anda kelola dan lihat set status penyebaran di tab State. Untuk informasi lebih lanjut, lihat bagian "Lihat gambaran generasi status" pada topik Kelola set status.

Jika penyebaran Anda menggunakan komputasi stateful, Anda harus mempertimbangkan apakah data state dapat digunakan kembali untuk penyebaran setelah peningkatan.
Sebelum meningkatkan versi mesin penyebaran, buat savepoint secara manual untuk penyebaran tersebut. Ini membantu Anda dengan cepat mengembalikan penyebaran jika terjadi pengecualian selama peningkatan. Untuk informasi lebih lanjut, lihat bagian "Buat savepoint secara manual" pada Manajemen set status.
Penting
- Secara umum, versi minor dari versi utama yang sama kompatibel satu sama lain. Namun, kompatibilitas antar versi utama tidak dijamin. Jika versi sebelum dan sesudah peningkatan kompatibel satu sama lain, versi baru mesin dapat membaca savepoint yang dihasilkan oleh versi lama mesin. Versi lama mesin mungkin tidak dapat membaca savepoint yang dihasilkan oleh versi baru mesin.
- Realtime Compute for Apache Flink yang menggunakan VVR 6.X atau lebih baru mendukung dua format savepoint: format native dan format standar. Format native mendukung pembuatan savepoint yang lebih cepat. Format standar memberikan kompatibilitas yang lebih baik. Oleh karena itu, jika Anda ingin meningkatkan versi mesin penyebaran ke versi minor terbaru dari versi utama yang sama, kami sarankan Anda menggunakan format native untuk pembuatan savepoint. Jika Anda ingin meningkatkan versi mesin penyebaran ke versi utama terbaru, kami sarankan Anda menggunakan format standar.
Jika penyebaran Anda adalah stateless, lanjutkan ke langkah berikutnya.

(Opsional) Langkah 3: Batalkan penyebaran

Di panel navigasi di sebelah kiri, pilih O&M > Deployments. Pada halaman Deployments, temukan penyebaran yang ingin Anda kelola dan klik Cancel di kolom Actions. Untuk informasi lebih lanjut, lihat Batalkan penyebaran.

Jika operator hilir mendukung operasi penulisan idempoten atau duplikasi data dapat diterima untuk bisnis Anda, Anda dapat menjalankan penyebaran dan penyebaran cadangan pada saat yang bersamaan.

Langkah 4: Mulai penyebaran baru

Jika penyebaran baru adalah stateful, lakukan operasi berikut untuk memulai penyebaran: Di panel Start Job, pilih Resume Mode, pilih Specific State, lalu pilih savepoint yang dibuat untuk penyebaran yang Anda buat cadangannya.
Jika penyebaran baru adalah stateless, Anda dapat memilih Initial Mode untuk memulai penyebaran.

Untuk informasi lebih lanjut tentang cara memulai penyebaran, lihat Mulai penyebaran.

Langkah 5: Periksa status online penyebaran baru dan hapus penyebaran yang Anda buat cadangannya

Dalam kebanyakan kasus, jika penyebaran dimulai sesuai harapan dan checkpoint pertama dihasilkan setelah peningkatan, peningkatan dianggap berhasil pada tahap awal. Kami sarankan Anda mengamati kebenaran data bisnis untuk memastikan integritas hasil peningkatan.

Jika penyebaran berjalan sesuai harapan dan kebenaran data diverifikasi, Anda dapat menghapus penyebaran dan savepoint yang dihasilkan sebelum peningkatan secara manual. Untuk informasi lebih lanjut tentang cara menghapus savepoint, lihat bagian "Hapus savepoint tertentu secara manual" pada Manajemen set status.

Pengembalian untuk kegagalan peningkatan

Jika penyebaran tidak dapat dimulai atau data bisnis tidak normal setelah peningkatan, kami sarankan Anda segera membatalkan penyebaran, mengubah versi mesin penyebaran ke versi sebelum peningkatan, lalu menggunakan savepoint yang disimpan sebelum peningkatan untuk memulihkan bisnis. Anda juga dapat submit a ticket untuk memberikan umpan balik.

Jika Anda tidak dapat melacak seluruh proses peningkatan, kami sarankan Anda mengonfigurasi peringatan kegagalan penyebaran untuk memberi tahu Anda tentang pengecualian secepat mungkin. Untuk informasi lebih lanjut, lihat Konfigurasi pemantauan dan peringatan.