View a markdown version of this page

Layanan Terkelola Amazon untuk Apache Flink 2.3 - Layanan Terkelola untuk Apache Flink

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

Layanan Terkelola Amazon untuk Apache Flink 2.3

Layanan Terkelola untuk Apache Flink sekarang mendukung Apache Flink versi 2.3.0. Bagian ini memperkenalkan Anda pada fitur-fitur baru utama dan perubahan yang diperkenalkan dengan Managed Service untuk Apache Flink dukungan Apache Flink 2.3.0.

catatan

Jika Anda menggunakan versi Apache Flink yang didukung sebelumnya dan ingin meningkatkan aplikasi yang ada ke Apache Flink 2.3.0, Anda dapat melakukannya menggunakan peningkatan versi Apache Flink di tempat. Untuk informasi selengkapnya, lihat Gunakan upgrade versi di tempat untuk Apache Flink. Dengan peningkatan versi di tempat, Anda mempertahankan keterlacakan aplikasi terhadap satu ARN di seluruh versi Apache Flink, termasuk snapshot, log, metrik, tag, konfigurasi Flink, dan banyak lagi.

catatan

Upgrade dari Flink 1.x ke Flink 2.3 adalah peningkatan versi utama dengan perubahan besar dan pertimbangan kompatibilitas status. Sebelum memutakhirkan dari 1.x, tinjau Melanggar perubahan dan penghentian danPanduan kompatibilitas status untuk peningkatan Flink 2.2.

Apache Flink 2.3.0 memperkenalkan peningkatan pada SQL API, pemilihan partisi adaptif untuk beban kerja miring, dan dasbor Flink.

Fitur yang didukung dan dokumentasi terkait

Fitur yang didukung

Deskripsi

Referensi dokumentasi Apache Flink

Perbaikan SinkUpsertMaterializer dan gangguan changelog

Meningkatkan urutan pembaruan saat menulis aliran CDC atau changelog untuk meningkatkan sink.

FLIP-558: Perbaikan SinkUpsertMaterializer dan gangguan changelog

Manajemen Aplikasi membaca API

Titik akhir read-only baru untuk pengamatan tingkat aplikasi. Titik akhir tulis dinonaktifkan di Amazon Managed Service untuk Apache Flink.

FLIP-549: Manajemen Aplikasi, FLIP-560: Peningkatan Kemampuan Manajemen Aplikasi

Pemilihan Partisi Adaptif untuk StreamPartitioner

Opt-in optimasi throughput untuk miring Rebalance dan Rescale partisi. Dinonaktifkan secara default; aktifkan dengantaskmanager.network.adaptive-partitioner.enabled.

FLIP-339: Pemilihan Partisi Adaptif untuk StreamPartitioner

catatan

Anda dapat memilih fitur berikut dengan mengirimkan kasus dukungan:

Opt-in fitur dan dokumentasi terkait

Opt-in fitur

Deskripsi

Referensi dokumentasi Apache Flink

Dukungan pos pemeriksaan selama pemulihan

Ini dinonaktifkan secara default karena ini adalah fitur eksperimental di open source. Anda dapat meminta untuk mengaktifkannya untuk aplikasi Anda menggunakan kasus dukungan.

FLIP-547: Mendukung pos pemeriksaan selama pemulihan

Untuk dokumentasi rilis Apache Flink 2.3.0, lihat Dokumentasi Apache Flink v2.3.0. Untuk catatan rilis Flink 2.3, lihat Catatan rilis - Flink 2.3.

Apache Flink 2.3 mengubah perilaku default penyelarasan tanda air untuk mencegah pekerjaan backlog menghabiskan semua sumber daya hilir. Di Amazon Managed Service for Apache Flink, nilai default pipeline.watermark-alignment.max-drift diatur 0 untuk mempertahankan kompatibilitas mundur dengan versi Apache Flink yang didukung sebelumnya dan melindungi aplikasi Anda yang ada dari regresi perilaku saat upgrade. Jika Anda menginginkan perilaku keadilan baru, Anda dapat ikut serta dengan menyetel secara pipeline.watermark-alignment.max-drift terprogram dalam kode aplikasi Anda. Untuk informasi selengkapnya, lihat FLINK-37399: Penjajaran tanda air mencegah pekerjaan yang backlog menggunakan semua sumber daya.

Komponen untuk Layanan Terkelola Amazon untuk Apache Flink 2.3

Komponen

Versi

Java

17 (disarankan)

Python

3.12

Kinesis Analisis Data Flink Runtime (aws-kinesisanalytics-runtime)

1.2.0

Konektor

Untuk informasi tentang konektor yang tersedia, lihat konektor https://docs.aws.amazon.com/managed-flink/latest/java/how-flink-connectors.html Apache Flink.

Fitur Apache Flink 2.3 berikut tidak didukung di Amazon Managed Service untuk Apache Flink:

  • Tabel Terwujud: Snapshot tabel yang dipelihara secara terus menerus dan dapat dikueri.

  • Perubahan Telemetri Kustom: Reporter metrik khusus dan konfigurasi telemetri.

  • Flink Native S3 FileSystem (FLIP-555): Implementasi sistem file S3 asli (eksperimental dalam sumber terbuka)

  • ForSt Status Backend: Penyimpanan status terpilah (eksperimental dalam sumber terbuka).

  • Java 21: Dukungan eksperimental dalam open source, tidak didukung dalam Layanan Terkelola untuk Apache Flink.

Flink 2.3 di Amazon Managed Service untuk Apache Flink tidak mendukung aplikasi Studio. Untuk informasi selengkapnya, lihat Membuat buku catatan Studio.