Mulai penyebaran Flink - Realtime Compute for Apache Flink

Setelah membuat penyebaran, Anda harus memulainya dari halaman Deployments. Memulai penyebaran juga diperlukan untuk melanjutkan penyebaran yang dihentikan atau menerapkan pembaruan parameter yang memerlukan restart.

Prasyarat

Penyebaran yang sudah ada diperlukan. Untuk informasi selengkapnya, lihat Buat penyebaran.

Batasan

Anda hanya dapat menentukan opsi startup untuk penyebaran streaming.

Tindakan Kewaspadaan

Jika penyebaran dimulai oleh RAM user, RAM role, atau Akun Alibaba Cloud lain, pastikan identitas tersebut memiliki akses ke namespace target. Untuk informasi selengkapnya, lihat Otorisasi akses ke konsol Flink yang sepenuhnya dikelola dan Kelola izin.
Jika Anda memulai penyebaran menggunakan opsi Latest State atau Specific State, sistem akan melakukan pemeriksaan kompatibilitas status. Memulai penyebaran dengan ketidakcocokan yang terdeteksi berisiko tinggi karena dapat gagal atau menghasilkan hasil yang tidak terduga. Untuk informasi selengkapnya, lihat Referensi kompatibilitas status Flink.

Prosedur

Buka dialog Start untuk penyebaran tersebut.
1. Login ke konsol Flink yang sepenuhnya dikelola sebagai pengguna yang memiliki peran owner untuk namespace tersebut.
2. Pada bilah navigasi atas, pilih namespace target.
3. Pada halaman O&M > Deployments, dari daftar drop-down, pilih streaming deployment atau batch deployment.
Temukan penyebaran target dan pada kolom Actions, klik Start.

(Opsional) Untuk penyebaran streaming, konfigurasikan opsi startup.

Initial mode

Pilih mode ini untuk penyebaran baru atau saat Anda tidak dapat menggunakan kembali status yang ada. Berdasarkan kebutuhan bisnis Anda, Anda juga dapat memutuskan apakah akan mengaktifkan Autopilot.

Catatan

Initial mode adalah startup tanpa status yang tidak menggunakan kembali status apa pun. Dari perspektif konektor sumber, ini setara dengan startup pertama kali, sehingga parameter posisi startup yang dikonfigurasi dalam DDL akan berlaku kembali. Misalnya, jika tabel sumber MySQL CDC menetapkan scan.startup.mode ke latest-offset, penyebaran hanya membaca dari offset terbaru saat ini setelah dimulai dalam Initial mode dan tidak memindai ulang seluruh data historis. Jika nilai default initial dipertahankan, penyebaran akan memindai ulang seluruh data historis.

Jika penyimpanan hulu memiliki batasan retensi data, seperti periode retensi log Simple Log Service (SLS) atau periode retensi pesan pada antrian pesan, rentang data yang dibaca kembali setelah startup dalam Initial mode dibatasi oleh periode retensi tersebut dan mungkin berbeda dari rentang data pada eksekusi pertama. Jika sink hilir menimpa data berdasarkan primary key, evaluasi periode retensi data hulu sebelum memulai penyebaran dalam Initial mode untuk mencegah penimpaan tak terduga pada tabel hasil.

Strategi

Deskripsi

Specify source's start time

Pilih Specify source's start time dan masukkan waktu tertentu.

Anda dapat menetapkan waktu mulai di UI untuk tujuh konektor berikut: Kafka, Log Service (SLS), DataHub, ApsaraMQ for RocketMQ, Hologres, Paimon, dan MySQL.

Waktu pembacaan data yang ditentukan pada antarmuka startup penyebaran memiliki prioritas lebih tinggi daripada startTime yang ditetapkan dalam kode DDL penyebaran.

Catatan

Versi Kafka sebelum 0.11 mungkin tidak didukung karena potensi ketidakcocokan dengan versi klien Kafka yang digunakan oleh konektor. Kami menyarankan Anda melakukan upgrade versi Kafka.
Tidak semua konektor mendukung konfigurasi parameter startTime. Untuk informasi selengkapnya, lihat parameter WITH untuk setiap konektor, seperti Parameter WITH Log Service (SLS), untuk memeriksa apakah startTime termasuk di dalamnya.
Hanya saat Anda memulai penyebaran baru dan menentukan startTime, maka startTime akan berlaku. Jika Anda memulai penyebaran dari checkpoint atau savepoint, menentukan startTime tidak berpengaruh.

Configure Autopilot

Aktifkan sakelar ini dan pilih mode tuning:

Autopilot Mode: Sistem secara otomatis menskalakan sumber daya ke bawah saat penggunaan rendah dan menskalakannya ke atas saat penggunaan mencapai ambang batas tertentu. Untuk informasi selengkapnya, lihat Aktifkan dan konfigurasikan Autopilot.
Scheduled Mode: Anda harus memilih jadwal dari daftar drop-down. Jadwal dapat berisi beberapa konfigurasi sumber daya untuk titik waktu berbeda. Anda dapat mengonfigurasi sumber daya berdasarkan pola penggunaan selama berbagai periode. Untuk informasi selengkapnya, lihat Konfigurasikan dan terapkan rencana tuning terjadwal.

Resume mode

Anda dapat memilih strategi startup berdasarkan kebutuhan bisnis dan memutuskan apakah akan mengaktifkan Autopilot.

Strategi	Deskripsi
Latest State	Menjalankan kembali penyebaran dari `savepoint` atau `checkpoint` terbaru yang tersedia. Jika Anda memilih opsi ini untuk penyebaran SQL, sistem Flink akan mendeteksi perubahan pada kode SQL, parameter runtime Flink, dan versi engine. Jika perubahan terdeteksi, kami menyarankan Anda mengklik Click to detect di samping State Compatibility untuk memeriksa kompatibilitas. Kemudian, lanjutkan berdasarkan hasilnya. Untuk informasi tentang hasil kompatibilitas dan tindakan yang disarankan, lihat Kompatibilitas.
Specific State	Pilih savepoint tertentu untuk dilanjutkan. Untuk mempelajari cara membuat savepoint, lihat Kelola status penyebaran.
Other deployment state	Setelah memilih opsi ini, tentukan penyebaran target dan savepoint-nya yang sesuai untuk dilanjutkan. Savepoint dapat dibagikan antar penyebaran, tetapi statusnya harus kompatibel. Untuk informasi selengkapnya, lihat Kelola status penyebaran.
Allow Non-restored State (AllowNonRestoredState) Catatan Opsi ini hanya didukung untuk penyebaran JAR.	Secara default, Flink mencoba memetakan seluruh savepoint ke operator penyebaran baru. Jika modifikasi pada penyebaran menyebabkan perubahan pada status operator, penyebaran mungkin gagal dilanjutkan. Aktifkan opsi ini untuk mengizinkan Flink melewati status apa pun yang tidak dapat dipetakan dan melanjutkan startup. Untuk informasi selengkapnya, lihat Allow Non-Restored State.
Configure Autopilot	Aktifkan sakelar ini dan pilih mode tuning: Autopilot Mode: Sistem secara otomatis menskalakan sumber daya ke bawah saat penggunaan rendah dan menskalakannya ke atas saat penggunaan mencapai ambang batas tertentu. Untuk informasi selengkapnya, lihat Aktifkan dan konfigurasikan Autopilot. Scheduled Mode: Anda harus memilih jadwal dari daftar drop-down. Jadwal dapat berisi beberapa konfigurasi sumber daya untuk titik waktu berbeda. Anda dapat mengonfigurasi sumber daya berdasarkan pola penggunaan selama berbagai periode. Untuk informasi selengkapnya, lihat Konfigurasikan dan terapkan rencana tuning terjadwal.

Klik Start.

Pada halaman O&M > Deployments, lihat status penyebaran. Untuk informasi selengkapnya, lihat Lihat status penyebaran.

Dokumen terkait

Setelah penyebaran dimulai, jika Anda perlu mengubah parameter runtime-nya, lihat Konfigurasikan parameter runtime. Beberapa parameter juga mendukung pembaruan parameter dinamis, yang menghindari downtime akibat menghentikan dan memulai ulang penyebaran. Untuk informasi selengkapnya, lihat Scaling dinamis dan pembaruan parameter dinamis.
Setelah penyebaran dimulai, jika Anda perlu melacak alur datanya untuk menemukan masalah atau menilai dampaknya, lihat Lihat alur data.
Untuk mempelajari tentang GeminiStateBackend tingkat enterprise dan perbandingan performanya dengan RocksDBStateBackend, lihat Pengenalan backend status tingkat enterprise.