Saat Anda membuat ruang kerja Flink, Flink membuat direktori di bucket OSS yang terkait. Direktori tersebut menyimpan file data yang diperlukan atau dihasilkan oleh pekerjaan Flink, seperti checkpoint sistem, snapshot pekerjaan, log, dan paket JAR. Topik ini menjelaskan cara mengunggah resource serta isi setiap direktori dalam bucket tersebut.
OSS Bucket
Deskripsi direktori
Jika Anda memilih OSS Bucket sebagai jenis penyimpanan saat membuat ruang kerja Flink, Flink akan membuat direktori berikut di bucket tersebut untuk menyimpan file yang sesuai.
Direktori | Konten |
artifacts | Menyimpan paket JAR yang diunggah, dependensi tambahan, file Python, dan dependensi Python. |
sql-artifacts | Menyimpan file yang diperlukan oleh user-defined function (UDF) dan konektor yang terdaftar. |
flink-jobs | Menyimpan informasi High Availability (HA) dan informasi checkpoint sistem untuk pekerjaan Flink. |
flink-savepoints | Menyimpan file snapshot yang dihasilkan setelah Anda mengklik Create Snapshot di Flink development console. |
flink-sessionclusters | Menyimpan informasi HA dan informasi checkpoint sistem untuk session cluster. |
plan | Menyimpan informasi konfigurasi resource saat Anda menggunakan mode expert. |
logs | Menyimpan log jika Anda mengonfigurasi pekerjaan untuk mengeluarkan log ke OSS. |
Manajemen file
Untuk ruang kerja yang menggunakan OSS Bucket, Anda hanya dapat mengunggah, mengunduh, dan menghapus file di direktori artifacts.
Masuk ke Flink console.
Klik Console pada kolom Actions ruang kerja yang dituju.
Di Object Storage Service (OSS) console, konfigurasikan aturan Berbagi Sumber Daya Lintas Asal (CORS) untuk OSS Bucket yang terhubung ke ruang kerja Flink.
Jika aturan CORS tidak dikonfigurasi, unggahan file mungkin gagal karena pembatasan lintas domain. Saat mengonfigurasi aturan CORS, atur Origin menjadi https://vvpsg.console.alibabacloud.com, pilih semua metode untuk Allowed Methods, dan atur Allowed Headers menjadi
*.
Pada panel navigasi kiri, klik File Management. Anda dapat melakukan operasi berikut.
Operasi
Deskripsi
Upload resource
Klik Upload Resource dan pilih file lokal untuk diunggah. Anda juga dapat menyeret file tersebut ke area daftar resource.
Setelah unggahan selesai, path file berformat
oss://<Nama OSS Bucket yang terhubung>/artifacts/namespaces/<Nama Proyek>/<Nama File>. Anda dapat mengklik nama file untuk menyalin path tersebut.Untuk informasi lebih lanjut tentang nama proyek, lihat Lihat dan hapus proyek.
Download resource
Pada kolom Actions, klik Download untuk mengunduh file dari OSS Bucket ke mesin lokal Anda guna dilihat.
Delete resource
Pada kolom Actions, klik Delete untuk menghapus file dari OSS Bucket.
Akselerasi transfer file
Untuk ruang kerja yang menggunakan OSS Bucket, jika Anda mengalami transfer file besar yang lambat dalam jarak jauh, Anda dapat mengaktifkan fitur akselerasi transfer. Fitur ini terletak di pojok kanan atas halaman dan meningkatkan kecepatan unggah dan unduh.
Untuk menggunakan fitur ini, Anda harus terlebih dahulu mengaktifkan fitur akselerasi transfer untuk OSS. Pengaktifan akselerasi transfer akan menimbulkan biaya trafik tambahan. Untuk informasi lebih lanjut tentang penagihan, lihat Biaya akselerasi transfer.
Referensi
Untuk informasi lebih lanjut tentang cara men-deploy pekerjaan SQL, JAR, dan Python, lihat Deploy a job.
Untuk informasi lebih lanjut tentang cara melihat log detail dari pekerjaan yang sedang berjalan, lihat View startup and operational logs.
Untuk informasi lebih lanjut tentang cara melihat checkpoint sistem dan snapshot pekerjaan, lihat Manage job state sets.