Pengaturan Apache Flink - Layanan Terkelola untuk Apache Flink
Konfigurasi Apache FlinkBackend negaraCheckpointingMenyimpanUkuran tumpukanBuffer debloating

Amazon Managed Service untuk Apache Flink sebelumnya dikenal sebagai Amazon Kinesis Data Analytics untuk Apache Flink.

Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

Pengaturan Apache Flink

Managed Service untuk Apache Flink adalah implementasi dari kerangka Apache Flink. Layanan Terkelola untuk Apache Flink menggunakan nilai default yang dijelaskan di bagian ini. Beberapa nilai ini dapat diatur oleh Layanan Terkelola untuk aplikasi Apache Flink dalam kode, dan lainnya tidak dapat diubah.

Gunakan tautan di bagian ini untuk mempelajari lebih lanjut tentang pengaturan Apache flink dan mana yang dapat dimodifikasi.

Topik ini berisi bagian-bagian berikut:

Managed Service for Apache Flink menyediakan konfigurasi Flink default yang terdiri dari nilai yang direkomendasikan Apache Flink untuk sebagian besar properti dan beberapa berdasarkan profil aplikasi umum. Untuk informasi selengkapnya tentang konfigurasi Flink, lihat Konfigurasi. Konfigurasi default yang disediakan layanan berfungsi untuk sebagian besar aplikasi. Namun, untuk mengubah properti konfigurasi Flink untuk meningkatkan kinerja untuk aplikasi tertentu dengan paralelisme tinggi, memori tinggi dan penggunaan status, atau mengaktifkan fitur debugging baru di Apache Flink, Anda dapat mengubah properti tertentu dengan meminta kasus dukungan. Untuk informasi selengkapnya, lihat Pusat Dukungan AWS. Anda dapat memeriksa konfigurasi saat ini untuk aplikasi Anda menggunakan Apache Flink Dashboard.

Backend negara

Layanan Terkelola untuk Apache Flink menyimpan data sementara di backend status. Managed Service untuk Apache Flink menggunakan R ocksDBState Backend. Memanggil setStateBackend untuk mengatur backend yang berbeda tidak memiliki pengaruh.

Kami mengaktifkan fitur berikut pada backend status:

  • Snapshot backend status tambahan

  • Snapshot backend status asinkron

  • Pemulihan lokal titik pemeriksaan

Untuk informasi selengkapnya tentang backend status, lihat Backend Status di Dokumentasi Apache Flink.

Checkpointing

Layanan Terkelola untuk Apache Flink menggunakan konfigurasi pos pemeriksaan default dengan nilai-nilai berikut. Beberapa nilai ini dapat diubah menggunakan CheckpointConfiguration. Anda harus mengatur CheckpointConfiguration.ConfigurationType untuk Managed Service CUSTOM for Apache Flink untuk menggunakan nilai checkpointing yang dimodifikasi.

Pengaturan Bisa dimodifikasi? Bagaimana nilai default
CheckpointingEnabled Dapat diubah

Buat Aplikasi

Perbarui Aplikasi

AWS CloudFormation

 True
CheckpointInterval Dapat diubah

Buat Aplikasi

Perbarui Aplikasi

AWS CloudFormation

 60000
MinPauseBetweenCheckpoints Dapat diubah

Buat Aplikasi

Perbarui Aplikasi

AWS CloudFormation

 5000
Pos pemeriksaan tidak selaras Dapat diubah Kasus Support False
Jumlah Titik Pemeriksaan Konkuren Tidak Dapat Dimodifikasi N/A 1
Mode Checkpointing Tidak Dapat Dimodifikasi N/A Tepat Satu Kali
Kebijakan Penyimpanan Titik Pemeriksaan Tidak Dapat Dimodifikasi N/A Pada Kegagalan
Waktu Habis Titik Pemeriksaan Tidak Dapat Dimodifikasi N/A 60 menit
Titik Pemeriksaan Maks. yang Disimpan Tidak Dapat Dimodifikasi N/A 1
Lokasi Titik Pemeriksaan dan Titik Simpan Tidak Dapat Dimodifikasi N/A Kami menyimpan data titik pemeriksaan dan titik simpan yang tahan lama ke bucket S3 milik layanan.

Menyimpan

Secara default, ketika memulihkan dari titik simpan, operasi lanjutkan akan mencoba memetakan semua status titik simpan kembali ke program yang Anda pulihkan. Jika Anda menghapus operator, secara default, memulihkan dari titik simpan yang memiliki data yang sesuai dengan operator yang hilang akan gagal. Anda dapat mengizinkan operasi berhasil dengan mengatur AllowNonRestoredStateparameter aplikasi FlinkRunConfigurationketrue. Ini akan memungkinkan operasi lanjutkan melewati status yang tidak dapat dipetakan ke program baru.

Untuk informasi selengkapnya, lihat Mengizinkan Status yang Tidak Dipulihkan di Dokumentasi Apache Flink.

Ukuran tumpukan

Managed Service for Apache Flink mengalokasikan masing-masing 3 KPU GiB JVM heap, dan mencadangkan 1 GiB untuk alokasi kode asli. Untuk informasi tentang meningkatkan kapasitas aplikasi Anda, lihat Menerapkan penskalaan aplikasi di Managed Service untuk Apache Flink.

Untuk informasi selengkapnya tentang ukuran JVM heap, lihat Konfigurasi dalam dokumentasi Apache Flink.

Buffer debloating

Buffer debloating dapat membantu aplikasi dengan tekanan balik tinggi. Jika aplikasi Anda mengalami pos pemeriksaan/savepoint yang gagal, mengaktifkan fitur ini bisa berguna. Untuk melakukan ini, minta kasus dukungan.

Untuk informasi selengkapnya, lihat Mekanisme Debloating Buffer di dokumentasi Apache Flink.