Mulai penerapan - Realtime Compute for Apache Flink

Setelah Anda mengembangkan draf dan menerapkannya sebagai Penyebaran, Anda harus memulai Penyebaran di halaman Penyebaran untuk menjalankannya. Jika Anda ingin melanjutkan Penyebaran yang dibatalkan, Anda juga perlu memulainya kembali. Setelah memodifikasi konfigurasi parameter yang tidak mendukung pembaruan dinamis, Anda harus memulai ulang Penyebaran agar modifikasi tersebut berlaku. Topik ini menjelaskan cara memulai Penyebaran.

Prasyarat

Penyebaran telah dibuat. Untuk informasi lebih lanjut, lihat Buat Penyebaran.

Batasan

Opsi startup hanya dapat ditentukan untuk Penyebaran streaming.

Peringatan

Jika Pengguna RAM, Peran RAM, atau Akun Alibaba Cloud lainnya ingin memulai Penyebaran, pastikan bahwa mereka memiliki izin untuk mengakses namespace tempat Penyebaran berada. Untuk informasi lebih lanjut, lihat Otorisasi akun untuk melakukan operasi dalam namespace dan Manajemen Izin.
Jika Anda memilih State Terbaru atau State Spesifik saat memulai Penyebaran, sistem akan melakukan pemeriksaan kompatibilitas data state. Jika Anda memulai Penyebaran yang tidak kompatibel dengan data state, Penyebaran mungkin gagal dimulai atau hasil operasi Penyebaran mungkin tidak sesuai dengan harapan Anda. Lanjutkan dengan hati-hati. Untuk informasi lebih lanjut, lihat Ikhtisar.

Prosedur

Buka panel Mulai Pekerjaan.
1. Masuk ke Konsol Flink yang sepenuhnya dikelola menggunakan anggota yang ditugaskan peran pemilik dalam sebuah namespace.
2. Di bilah navigasi atas, pilih namespace dari daftar drop-down.
3. Di halaman O&M > Deployments, pilih STREAM atau BATCH dari daftar drop-down jenis Penyebaran.
Temukan Penyebaran yang diinginkan dan klik Start di kolom Actions.

(Opsional) Di panel Start Job, konfigurasikan parameter startup. Langkah ini hanya diperlukan untuk Penyebaran streaming.

Initial Mode

Pilih opsi ini jika Anda memulai Penyebaran untuk pertama kali tanpa perlu menggunakan kembali status atau jika Penyebaran tidak dapat menggunakan kembali status. Jika Anda memilih opsi ini, tentukan apakah akan mengaktifkan penyetelan otomatis berdasarkan kebutuhan bisnis Anda.

Strategi

Deskripsi

Specify source's start time

Jika Anda memilih Initial Mode, Anda dapat mengaktifkan Specify source's start time untuk menentukan waktu mulai membaca data.

Konektor yang didukung: Kafka, SLS, DataHub, ApsaraMQ for RocketMQ, Hologres, Paimon, dan MySQL.

Parameter Specify source's start time yang dikonfigurasi di panel Start Job memiliki prioritas lebih tinggi daripada parameter startTime yang dikonfigurasi dalam kode DDL draf.

Catatan

Pada versi Kafka sebelum 0.11, parameter ini mungkin tidak didukung karena masalah ketidakcocokan pada versi Klien Kafka yang digunakan oleh konektor. Kami sarankan Anda meningkatkan versi Kafka.
Tidak semua konektor mendukung konfigurasi parameter startTime. Anda dapat melihat parameter dalam klausa WITH setiap jenis konektor untuk memeriksa apakah tipe konektor mendukung konfigurasi parameter startTime. Untuk informasi lebih lanjut tentang parameter dalam klausa WITH suatu tipe konektor, lihat topik terkait dari tipe konektor tertentu, seperti Parameter dalam klausa WITH dalam Membuat tabel sumber Layanan Log.
Parameter startTime hanya berlaku jika Penyebaran baru dimulai dan parameter startTime dikonfigurasi. Jika Anda memulai Penyebaran berdasarkan checkpoint atau titik simpan, parameter startTime tidak akan berlaku meskipun parameter ini dikonfigurasi.

Configure Autopilot

Jika Anda menghidupkan saklar ini, Anda perlu mengonfigurasi parameter Mode Penyetelan Sumber Daya. Nilai valid:

Mode Autopilot: Saat penggunaan sumber daya rendah, sistem secara otomatis menurunkan spesifikasi konfigurasi sumber daya. Saat penggunaan sumber daya mencapai ambang batas tertentu, sistem secara otomatis meningkatkan konfigurasi sumber daya. Untuk informasi lebih lanjut, lihat Aktifkan dan konfigurasikan Autopilot.
Mode Terjadwal: Jika Anda mengatur parameter Mode Penyetelan Sumber Daya ke Mode Terjadwal, Anda harus memilih rencana terjadwal dari daftar drop-down Rencana Terjadwal yang Ada. Sebuah rencana dapat berisi pemetaan antara beberapa kelompok sumber daya dan titik waktu. Anda dapat mengonfigurasi sumber daya berdasarkan penggunaan sumber daya selama setiap periode waktu. Untuk informasi lebih lanjut, lihat Konfigurasikan dan terapkan rencana terjadwal.

Resume Mode

Pilih strategi startup dan tentukan apakah akan mengaktifkan penyetelan otomatis berdasarkan kebutuhan bisnis Anda.

Strategi	Deskripsi
Latest State	Jika Anda ingin melanjutkan Penyebaran dari state terbaru titik simpan atau checkpoint, pilih opsi ini. Jika Anda memilih opsi ini untuk memulai Penyebaran SQL, Realtime Compute for Apache Flink mendeteksi perubahan pada pernyataan SQL, konfigurasi parameter runtime, dan versi mesin Penyebaran. Jika perubahan Penyebaran terdeteksi, kami sarankan Anda klik Click to detect di sebelah State Compatibility untuk memeriksa kompatibilitas. Kemudian, tentukan tindakan selanjutnya berdasarkan hasil pemeriksaan kompatibilitas. Untuk informasi lebih lanjut tentang hasil pemeriksaan kompatibilitas dan saran, lihat Kompatibilitas.
Specific State	Jika Anda ingin melanjutkan Penyebaran dari titik simpan Penyebaran saat ini, pilih opsi ini. Untuk informasi lebih lanjut tentang cara membuat titik simpan, lihat Kelola set state.
Status Penerapan Lainnya	Jika Anda memilih opsi ini, Anda harus menentukan titik simpan Penyebaran lain untuk melanjutkan Penyebaran saat ini. Hanya Penyebaran antara mana data state kompatibel yang dapat berbagi titik simpan. Untuk informasi lebih lanjut, lihat Kelola set state.
Allow Non-restored State Catatan Parameter ini hanya tersedia untuk Penyebaran JAR.	Secara default, Flink yang sepenuhnya dikelola mencoba mencocokkan semua titik simpan dengan Penyebaran yang sedang dipublikasikan. Jika status operator berubah karena modifikasi Penyebaran, tugas Penyebaran mungkin tidak dapat dipulihkan. Jika Anda menghidupkan saklar ini, Flink yang sepenuhnya dikelola melewati state yang tidak cocok dengan Penyebaran dan mengizinkan Penyebaran untuk dimulai. Untuk informasi lebih lanjut tentang Allow Non-Restored State, lihat Allow None-Restored State.
Configure Autopilot	Jika Anda menghidupkan saklar ini, Anda perlu mengonfigurasi parameter Mode Penyetelan Sumber Daya. Nilai valid: Mode Autopilot: Saat penggunaan sumber daya rendah, sistem secara otomatis menurunkan spesifikasi konfigurasi sumber daya. Saat penggunaan sumber daya mencapai ambang batas tertentu, sistem secara otomatis meningkatkan konfigurasi sumber daya. Untuk informasi lebih lanjut, lihat Aktifkan dan konfigurasikan Autopilot. Mode Terjadwal: Jika Anda mengatur parameter Mode Penyetelan Sumber Daya ke Mode Terjadwal, Anda harus memilih rencana terjadwal dari daftar drop-down Rencana Terjadwal yang Ada. Sebuah rencana dapat berisi pemetaan antara beberapa kelompok sumber daya dan titik waktu. Anda dapat mengonfigurasi sumber daya berdasarkan penggunaan sumber daya selama setiap periode waktu. Untuk informasi lebih lanjut, lihat Konfigurasikan dan terapkan rencana terjadwal.

Di panel Mulai Pekerjaan, klik Start.
Di halaman O&M > Deployments, periksa status Penyebaran. Untuk informasi lebih lanjut, lihat Lihat status Penyebaran.

Referensi

Setelah Penyebaran dimulai, Anda dapat mengonfigurasi parameter untuk Penyebaran. Untuk informasi lebih lanjut, lihat Parameter. Anda dapat memperbarui secara dinamis konfigurasi parameter tertentu dari Penyebaran, mengurangi waktu gangguan layanan yang disebabkan oleh dimulai dan dibatalkannya Penyebaran. Untuk informasi lebih lanjut, lihat Perbarui konfigurasi parameter secara dinamis untuk skalabilitas dinamis.
Setelah Penyebaran dimulai, Anda dapat menggunakan fitur alur data untuk melacak data dalam Penyebaran. Dengan cara ini, Anda dapat mengidentifikasi masalah dan mengevaluasi dampak dari masalah tersebut. Untuk informasi lebih lanjut, lihat Lihat alur data.
Anda dapat mempelajari tentang penyimpanan backend state tingkat perusahaan GeminiStateBackend dan perbandingan kinerja antara GeminiStateBackend dan RocksDBStateBackend. Untuk informasi lebih lanjut, lihat GeminiStateBackend.