Antrian sumber daya di Realtime Compute for Apache Flink mengisolasi dan mengalokasikan sumber daya komputasi di seluruh deployment dalam satu namespace. Setiap namespace mencakup antrian default bernama default-queue. Buat antrian kustom untuk mencegah satu deployment atau pengguna mengonsumsi seluruh sumber daya yang tersedia dan menyebabkan kegagalan bagi pengguna lain.
Catatan penggunaan
Antrian hanya dapat berjalan dalam exclusive mode. Antrian tidak dapat berjalan dalam mode preemption. Jika suatu antrian berjalan dalam mode preemption, sumber daya dalam antrian tersebut tidak dapat dipreempt.
Setelah sumber daya tertentu dalam suatu antrian dilepas, sumber daya tersebut dapat digunakan oleh deployment baru.
Jika tidak ada antrian kustom, semua deployment berjalan di
default-queue.
Menetapkan antrian ke workload
| Jenis Beban Kerja | Lokasi pengaturan | Parameter | Referensi |
|---|---|---|---|
| Deployment | Deploy draft dialog box | Deployment Target | Create a deployment |
| Session cluster | Standard section of the Create Session Cluster page | Deployment Target | Create a session cluster |
| Workflow | Create Workflow panel | Resource Queue | Manage workflows |
Langkah-langkah umum di Konsol
Prosedur Add, Edit, dan Delete semuanya dimulai dengan langkah navigasi yang sama:
Temukan ruang kerja target dan klik Console di kolom Actions.
Di panel navigasi sebelah kiri, pilih O&M > Queue Management.
Tambahkan antrian
Aturan penamaan antrian
| Aturan | Detail |
|---|---|
| Keunikan | Harus unik dalam namespace |
| Panjang | Maksimal 32 karakter |
| Karakter | Hanya huruf kecil, angka, dan tanda hubung (-) |
| Mutabilitas | Tidak dapat diubah setelah dibuat |
Prosedur
Selesaikan langkah-langkah umum di Konsol.
Di pojok kiri atas halaman Queue Management, klik Add queue.
Konfigurasikan parameter antrian. Parameter berbeda tergantung pada apakah sumber daya elastis dialokasikan ke namespace.
Namespace tanpa sumber daya elastis
Berlaku ketika metode penagihan ruang kerja adalah pay-as-you-go, subscription, atau Hybrid billing dan tidak ada sumber daya elastis yang dialokasikan ke namespace.
Parameter Deskripsi Queue Name Masukkan nama yang mengikuti aturan penamaan antrian. Resources (CU) Jumlah CU yang tersedia untuk antrian. Nilai maksimum sama dengan jumlah CU yang belum dialokasikan di namespace. Jika CU yang tersedia tidak mencukupi, konfigurasi ulang CU di antrian lain (lihat Edit a queue) atau tingkatkan sumber daya namespace (lihat Reconfigure resources). Namespace dengan sumber daya elastis
Berlaku ketika metode penagihan ruang kerja adalah Hybrid billing dan sumber daya elastis dialokasikan ke namespace.
Parameter Deskripsi Queue Name Masukkan nama yang mengikuti aturan penamaan antrian. Fixed Resources (CUs) Jumlah CU tetap yang tersedia untuk antrian. Jika CU tetap yang tersedia tidak mencukupi, sesuaikan sumber daya menggunakan metode ruang kerja subscription. Lihat Reconfigure resources. Elastic Resources (CUs) Jumlah CU elastis yang tersedia untuk antrian. Halaman Queue Management menampilkan jumlah maksimum CU elastis yang dapat dialokasikan. Jika CU elastis yang tersedia tidak mencukupi, sesuaikan sumber daya menggunakan metode ruang kerja pay-as-you-go. Lihat Reconfigure resources. Klik OK.
Edit antrian
Sesuaikan alokasi CU untuk antrian yang sudah ada saat kebutuhan sumber daya berubah.
Selesaikan langkah-langkah umum di Konsol.
Temukan antrian target dan klik Edit di kolom Actions.
Di dialog box Edit Queue, perbarui nilai sumber daya. Untuk deskripsi parameter, lihat Add a queue.
PentingNilai Resources (CU) tidak boleh ditetapkan lebih rendah dari jumlah CU yang sedang digunakan oleh antrian.
Klik OK.
Hapus antrian
Antrian default (
default-queue) tidak dapat dihapus.Antrian yang memiliki deployment yang sedang berjalan tidak dapat dihapus.
Menghapus antrian yang direferensikan oleh suatu deployment akan menyebabkan error saat deployment tersebut dijalankan ulang.
Selesaikan langkah-langkah umum di Konsol.
Temukan antrian target, klik Delete di kolom Actions, lalu klik OK.
Kasus penggunaan
Isolasi workload batch: Tetapkan deployment batch ke antrian khusus agar tidak menghabiskan sumber daya job lainnya.
Prioritaskan job kritis: Gabungkan antrian dengan fitur Workflows (public preview) untuk mengatur prioritas penjadwalan draft batch.
Referensi
Reconfigure resources – Sesuaikan sumber daya namespace atau batas kuota.
Create a deployment – Buat deployment SQL, JAR, atau Python.
Create a session cluster – Siapkan session cluster untuk debugging.
Workflows (public preview) – Jadwalkan dan prioritaskan deployment batch.