View a markdown version of this page

Layanan Dikelola 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 Dikelola Amazon untuk Apache Flink 2.3

Managed Service untuk Apache Flink sekarang mendukung Apache Flink versi 2.3.0. Bagian ini memperkenalkan Anda pada fitur baru utama dan perubahan yang diperkenalkan dengan Layanan Terkelola untuk dukungan Apache Flink 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 upgrade versi Apache Flink di tempat. Untuk informasi selengkapnya, lihat Gunakan upgrade versi di tempat untuk Apache Flink. Dengan peningkatan versi di tempat, Anda mempertahankan ketertelusuran aplikasi terhadap satu ARN di seluruh versi Apache Flink, termasuk snapshot, log, metrik, tag, konfigurasi Flink, dan banyak lagi.

catatan

Memutakhirkan dari Flink 1.x ke Flink 2.3 adalah peningkatan versi utama dengan perubahan yang melanggar dan pertimbangan kompatibilitas status. Sebelum memutakhirkan dari 1.x, tinjau Melanggar perubahan dan penghentian dan. Panduan kompatibilitas status untuk peningkatan Flink 2.2

Apache Flink 2.3.0 memperkenalkan peningkatan dalam 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 hanya-baca baru untuk observabilitas 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 partisi. Rescale Dinonaktifkan secara default; aktifkan dengantaskmanager.network.adaptive-partitioner.enabled.

FLIP-339: Pemilihan Partisi Adaptif untuk StreamPartitioner

catatan

Anda dapat memilih fitur-fitur berikut dengan mengirimkan kasus dukungan:

Opt-in fitur dan dokumentasi terkait

Opt-in fitur

Deskripsi

Referensi dokumentasi Apache Flink

Support pos pemeriksaan selama pemulihan

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

FLIP-547: Support pos pemeriksaan selama pemulihan

Untuk dokumentasi rilis Apache Flink 2.3.0, lihat Apache Flink Documentation 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 ditetapkan 0 untuk mempertahankan kompatibilitas mundur dengan versi Apache Flink yang didukung sebelumnya dan melindungi aplikasi yang ada dari regresi perilaku saat upgrade. Jika Anda menginginkan perilaku keadilan yang baru, Anda dapat ikut serta dengan menyetel pipeline.watermark-alignment.max-drift secara terprogram dalam kode aplikasi Anda. Untuk informasi selengkapnya, lihat FLINK-37399: Penyelarasan tanda air mencegah pekerjaan yang di-backlog menggunakan semua sumber daya.

Komponen untuk Amazon Managed Service untuk Apache Flink 2.3

Komponen

Versi

Java

17 (disarankan)

Python

3.12

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

1.2.0

Konektor

Untuk informasi tentang konektor yang tersedia, lihat konektor 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 open source)

  • ForSt State Backend: Penyimpanan status terpilah (eksperimental di open source).

  • Java 21: Dukungan eksperimental di open source, tidak didukung di Managed Service 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.