Topik ini menjawab pertanyaan umum mengenai pengelolaan dan penggunaan ruang kerja, namespace, serta penerapan Realtime Compute for Apache Flink, mencakup penskalaan sumber daya, cara melihat ID ruang kerja, memeriksa versi engine, dan mengonfigurasi parameter penerapan.
-
Manajemen ruang kerja dan namespace
-
Bagaimana cara melihat informasi ruang kerja seperti ID ruang kerja?
-
Apa yang harus saya lakukan jika alokasi sumber daya gagal saat melakukan scale-in pada namespace?
-
Bagaimana cara melihat ID AccessKey dan AccessKey Secret saya?
-
Bagaimana cara mengunggah file ke OSS agar dapat digunakan oleh penerapan Flink?
-
Mengapa ruang kerja Flink yang telah diaktifkan tidak ditampilkan di Konsol?
-
Error: Has not enough ip address: abnormal event detected from kubernetes
-
Manajemen penerapan
-
Bagaimana cara mengonfigurasi parameter running kustom untuk suatu penerapan?
-
Bagaimana cara menyimpan konfigurasi Flink umum secara persisten untuk meningkatkan efisiensi?
-
Bagaimana cara mencegah kebocoran informasi sensitif seperti pasangan AccessKey atau kata sandi?
-
Bagaimana cara mengoptimalkan pemanfaatan sumber daya untuk penerapan Flink?
Apakah saya dapat mengubah nama ruang kerja?
-
Di Konsol Realtime Compute for Apache Flink, temukan ruang kerja target dan klik di kolom Actions.
-
Klik nama ruang kerja untuk mengubahnya.
Apakah saya dapat mengubah VPC dan vSwitch?
Anda tidak dapat mengubah Virtual Private Cloud (VPC), tetapi Anda dapat mengubah vSwitch.
Lihat informasi ruang kerja
Di Konsol Realtime Compute for Apache Flink, temukan ruang kerja target dan klik di kolom Actions untuk melihat informasi seperti ID ruang kerja.
Panel Workspace Details juga berisi informasi seperti Workspace name, OSS bucket, VPC name and ID, Processor architecture, Resource group, dan vSwitch.
Alokasi sumber daya gagal saat scale-in namespace
-
Deskripsi masalah
Alokasi sumber daya gagal saat Anda melakukan scale-in pada namespace.
Pesan error berbunyi: "Alokasi sumber daya Namespace gagal. Buka halaman Konsol untuk menyesuaikan sumber daya antrian, lalu coba lagi."
-
Penyebab
Semua sumber daya yang tersedia telah dialokasikan atau sedang digunakan.
-
Solusi
Pertama-tama, kurangi sumber daya yang dialokasikan ke antrian sumber daya, lalu lakukan scale-in pada namespace. Untuk informasi lebih lanjut, lihat Modify resource quotas.
Di halaman Namespace Resources, temukan antrian sumber daya target dalam daftar antrian dan klik Edit a queue di kolom Actions untuk mengurangi CU yang dialokasikan.
Perubahan sumber daya tidak berlaku setelah scale-out
-
Langganan
Penskalaan sumber daya untuk Realtime Compute for Apache Flink mengikuti pendekatan top-down. Anda mengalokasikan sumber daya dari ruang kerja ke namespace-nya, lalu dari namespace ke antrian sumber daya masing-masing. Untuk informasi lebih lanjut, lihat Scale resources.
-
Pay-as-you-go
Dengan metode penagihan pay-as-you-go, Anda ditagih berdasarkan penggunaan sumber daya aktual. Penskalaan sumber daya tidak berlaku. Anda dapat menemukan ruang kerja target dan memilih di kolom Actions. Kemudian, konfigurasikan antrian sumber daya dalam namespace untuk memenuhi kebutuhan isolasi dan manajemen sumber daya dalam skenario pemrosesan batch. Untuk informasi lebih lanjut, lihat Manage resource queues.
Lihat ID AccessKey dan AccessKey Secret
-
ID AccessKey
-
Untuk akun root: Masuk ke Konsol Alibaba Cloud. Arahkan kursor ke gambar profil Anda di pojok kanan atas dan klik AccessKey Management untuk melihat ID tersebut.
-
Untuk pengguna RAM, lihat Melihat informasi AccessKey pengguna RAM.
-
-
AccessKey Secret
Untuk mengurangi risiko kebocoran, AccessKey Secret baik untuk akun root maupun pengguna RAM hanya ditampilkan saat pembuatan dan tidak dapat diambil kembali nanti. Anda harus menyimpan AccessKey Secret secara aman saat membuatnya.
Jika Anda belum memiliki pasangan AccessKey atau kehilangan AccessKey Secret, lihat Create an AccessKey pair.
Unggah file ke OSS untuk penerapan Flink
Saat mengaktifkan ruang kerja Flink, Anda dapat menentukan bucket Object Storage Service (OSS) untuk penyimpanan. Hal ini memungkinkan Anda mengunggah file ke bucket tersebut untuk digunakan dalam penerapan Flink. Anda juga dapat mengunggah file langsung di halaman Artifacts di Konsol pengembangan Realtime Compute for Apache Flink. Untuk informasi lebih lanjut, lihat Artifacts.
-
Di Konsol manajemen Real-time Compute, klik di kolom Actions ruang kerja target untuk melihat informasi bucket OSS terkait.
-
Unggah file sumber daya ke bucket OSS target.
-
Masuk ke Konsol OSS dan unggah file sumber daya ke direktori /artifacts/namespaces bucket target.
-
Unggah file sumber daya dengan memanggil operasi API PutObject. Untuk informasi lebih lanjut, lihat PutObject.
-
-
Di bilah navigasi kiri Konsol pengembangan Realtime Compute, klik Artifacts untuk melihat file sumber daya yang diunggah dari Konsol OSS.
Halaman ini mencantumkan file yang diunggah dengan kolom Name, Creation time, dan Actions (Download, Delete). Tombol Upload resource tersedia di bagian atas halaman.
Ruang kerja Flink tidak ditampilkan di Konsol
Periksa kemungkinan penyebab berikut. Jika masalah tetap berlanjut, Anda dapat membuat tiket untuk mendapatkan dukungan.
-
Pastikan ruang kerja Flink telah selesai diinisialisasi. Proses ini biasanya memakan waktu 5 hingga 10 menit.
-
Pastikan Anda telah memilih wilayah yang benar di bagian atas halaman Konsol. Ruang kerja hanya ditampilkan di wilayah tempat ruang kerja tersebut dibuat.
-
Jika Anda masuk sebagai pengguna RAM, pastikan pengguna tersebut memiliki izin yang diperlukan untuk Konsol Realtime Compute for Apache Flink. Untuk informasi lebih lanjut mengenai konfigurasi izin, lihat Permissions.
Error: Tidak cukup alamat IP
-
Detail galat
Has not enough ip address:abnormal event detected from kubernetes (type:[Warning], reason:[CniError_CodeUnKnownErr], message:[CniAllocateError: allocateIP failed: ipamCreate failed: failed to create ENI: all vSwitches ([*****]) cannot be used: CreateNetworkInterface: RequestId: 67959AE5-EA20-5CB4-8560-5BD6752472FD, ErrorCode: InvalidVSwitchId.IpNotEnough, Message: The specified VSwitch "*****" has not enough IpAddress., elapsedTime: 245.03232ms]) -
Penyebab
vSwitch tidak memiliki alamat IP yang tersedia.
-
Solusi
Ganti ke vSwitch yang memiliki alamat IP tersedia yang mencukupi. Untuk informasi lebih lanjut, lihat Change a vSwitch.
Error: Tanggapan kegagalan HTTP
-
Detail error
Pengunggahan file gagal dengan pesan error berikut.

-
Penyebab
Domain Konsol situs Internasional Alibaba Cloud telah berubah. Jika Anda menggunakan domain alibabacloud.com yang baru untuk mengunggah file tanpa terlebih dahulu mengonfigurasi aturan Berbagi sumber daya lintas asal (CORS) di Object Storage Service (OSS), permintaan akan gagal karena pembatasan lintas asal.
-
Solusi
Di Konsol OSS, konfigurasikan aturan CORS untuk bucket OSS yang terikat dengan ruang kerja Flink Anda. Untuk petunjuk spesifik, lihat Artifacts.
Lihat versi Flink dari suatu penerapan
Anda dapat memeriksa versi dengan salah satu cara berikut:
-
Di halaman ETL atau Data ingestion, klik Configurations di sisi kanan. Versi ditampilkan di bidang Engine Version.
-
Di halaman , klik nama penerapan target. Di tab Configuration, lihat informasi versi di bagian Basic.
Bidang Engine Version menampilkan versi Flink, misalnya,
vvr-8.0.9-flink-1.17.
Mengubah versi engine untuk suatu penerapan
-
Untuk penerapan SQL atau YAML
Di halaman ETL atau Data ingestion, klik Configurations di sisi kanan dan pilih versi target dari daftar drop-down Engine Version. Jika penerapan sudah berjalan, Anda harus menerapkan ulang dan menjalankannya agar perubahan versi berlaku.
-
Untuk penerapan JAR atau Python
Di halaman Deployments, klik nama penerapan target. Di tab Configuration, klik Edit di pojok kanan atas bagian Basic. Pilih versi target dari daftar drop-down Engine Version, klik Save, lalu klik Start.
Mengonfigurasi parameter berjalan kustom
-
Masuk ke Konsol Realtime Compute for Apache Flink.
-
Temukan ruang kerja target dan klik Console di kolom Actions.
-
Di halaman Deployments, klik nama penerapan target.
-
Di tab Configuration, klik Edit di pojok kanan atas bagian Parameters.
-
Di bidang Other configuration, masukkan konfigurasi parameter.
Pastikan terdapat spasi setelah tanda titik dua (:) pada setiap pasangan kunci-nilai. Berikut adalah contoh kode.
task.cancellation.timeout: 180s -
Klik Save.
Simpan konfigurasi Flink umum secara persisten
Realtime Compute for Apache Flink menyediakan fitur deployment template untuk menyimpan parameter yang sering digunakan sebagai nilai default. Hal ini menghindari kebutuhan untuk mengonfigurasi secara manual setiap penerapan baru.
Di panel navigasi sebelah kiri, klik Configuration Management dan pilih tab Default deployment configuration. Di sub-tab Streaming deployment atau Batch deployment, Anda dapat mengatur parameter running seperti Checkpoint interval, Min pause between checkpoints, Checkpoint timeout, State TTL, dan Flink restart strategy (misalnya, Fixed Delay). Setelah selesai mengonfigurasi, klik Save changes.
Cegah kebocoran informasi sensitif
Gunakan variabel untuk menghindari risiko keamanan akibat mengekspos informasi sensitif seperti pasangan AccessKey dan kata sandi dalam teks biasa. Menggunakan kembali variabel juga mencegah Anda menulis ulang kode atau nilai yang sama berulang kali, sehingga menyederhanakan manajemen konfigurasi. Anda dapat menggunakan variabel dalam berbagai skenario, termasuk penerapan SQL, penerapan JAR atau Python, konfigurasi logging, dan pengaturan UI. Untuk informasi lebih lanjut, lihat Manage variables.
Optimalkan pemanfaatan sumber daya untuk penerapan Flink
Anda dapat menyesuaikan sumber daya dengan cara berikut:
-
Penyesuaian manual: Di tab Diagnosis, klik Diagnose untuk melihat kesimpulan analisis sumber daya dan menyesuaikan sumber daya secara manual sesuai saran.
Setelah diagnosis selesai, halaman akan menampilkan hasilnya (misalnya, All 5 checks passed. No fixable issues found.). Anda dapat membuka bagian Resource analysis untuk melihat kesimpulan detail.
-
Penyesuaian otomatis: Aktifkan fitur tuning otomatis, yang mencakup mode tuning cerdas dan terjadwal, agar sistem Flink dapat menyesuaikan sumber daya secara otomatis. Untuk informasi lebih lanjut mengenai kasus penggunaan dan konfigurasi, lihat Configure automatic tuning.
Sintaks ekspresi Cron
Manajemen state menggunakan sintaks ekspresi Cron bergaya Unix, sedangkan orkestrasi alur menggunakan sintaks bergaya Java. Pastikan Anda menggunakan ekspresi Cron yang tepat untuk setiap skenario.
Sintaks bergaya Unix
-
Ekspresi bergaya Unix memiliki lima bidang:
minute hour day-of-month month day-of-week. -
Gabungan Day-of-Month dan Day-of-Week: Jika Anda menentukan nilai untuk bidang ketiga (day-of-month) dan bidang kelima (day-of-week), keduanya digabungkan dengan operator logika OR.
Ekspresi
0 12 1 * 5berarti tugas dijalankan pukul 12:00 siang pada tanggal 1 setiap bulan ATAU setiap hari Jumat. Ini tidak berarti tugas hanya dijalankan jika tanggal 1 juga bertepatan dengan hari Jumat. -
Tanda tanya tidak didukung
?: Jangan gunakan?karena sistem akan melaporkan error atau gagal mengenalinya. Jika Anda ingin mengabaikan suatu bidang, Anda hanya dapat menggunakan*.
Bergaya Java (Quartz) sintaks
-
Ekspresi bergaya Java biasanya menggunakan enam bidang:
second minute hour day-of-month month day-of-week. -
Konflik antara Day-of-Month dan Day-of-Week:
-
Anda tidak dapat menentukan nilai untuk kedua bidang day-of-month dan day-of-week secara bersamaan (atau mengatur keduanya ke
*). -
Untuk menghindari konflik logis, seperti menentukan tanggal 1 setiap bulan sekaligus hari Jumat ketika tanggal 1 bukan hari Jumat, salah satu dari dua bidang ini harus diatur ke
?. -
Aturan: Jika Anda menentukan Day-of-month, maka Day-of-week harus
?. Jika Anda menentukan Day-of-week, maka Day-of-month harus?.
-
-
Nilai Day-of-Week yang berbeda: 1 merepresentasikan Minggu, 2 merepresentasikan Senin, dan seterusnya. Kami menyarankan menggunakan singkatan bahasa Inggris (
SUN,MON,TUE) untuk menghindari kebingungan.