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 1.20
Layanan Terkelola untuk Apache Flink sekarang mendukung Apache Flink versi 1.20.5. Bagian ini memperkenalkan Anda pada fitur-fitur baru utama dan perubahan yang diperkenalkan dengan Managed Service untuk Apache Flink dukungan Apache Flink 1.20.5. Apache Flink 1.20 diharapkan menjadi rilis 1.x terakhir dan versi dukungan jangka panjang Flink (LTS). Untuk informasi selengkapnya, lihat FLIP-458: Long-Term Dukungan untuk Rilis Akhir Apache Flink 1.x Line.
catatan
Jika Anda menggunakan versi Apache Flink yang didukung sebelumnya dan ingin meningkatkan aplikasi yang ada ke Apache Flink 1.20.5, 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.
Fitur yang didukung
Apache Flink 1.20.5 memperkenalkan peningkatan pada API SQL, di DataStream API, dan di dasbor Flink.
| Fitur yang didukung | Deskripsi | Referensi dokumentasi Apache Flink |
|---|---|---|
| Tambahkan klausa DISTRIBUTED BY | Banyak mesin SQL mengekspos konsepPartitioning,Bucketing, atauClustering. Flink 1.20 memperkenalkan konsep Bucketing ke Flink. |
FLIP-376: Tambahkan klausa DISTRIBUTED BY |
| DataStream API: Mendukung Penyelesaian Partisi Penuh | Flink 1.20 memperkenalkan dukungan bawaan untuk agregasi pada aliran non-kunci melalui API. FullPartitionWindow |
FLIP-380: Mendukung Pemrosesan Partisi Penuh pada Non-keyed DataStream |
| Tampilkan skor kemiringan data di Dasbor Flink | Dasbor Flink 1.20 sekarang menunjukkan infrmasi kemiringan data. Setiap operator pada UI grafik pekerjaan Flink menunjukkan skor kemiringan data tambahan. | FLIP-418: Tampilkan skor kemiringan data di Dasbor Flink |
Untuk dokumentasi rilis Apache Flink 1.20.5, lihat Dokumentasi Apache Flink v1.20.5
Komponen-komponen
| Komponen | Versi |
|---|---|
| Java | 11 (direkomendasikan) |
| Python |
3.11 |
| 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. |
| Apache Beam (hanya aplikasi Beam) |
Dari versi 2.70.0. Untuk informasi selengkapnya, lihat Kompati bilitas Versi |
Masalah yang diketahui
Layanan Terkelola Amazon untuk Apache Flink Studio
Amazon Managed Service for Apache Flink Studio menggunakan notebook Apache Zeppelin untuk memberikan pengalaman pengembangan antarmuka tunggal untuk mengembangkan, men-debug kode, dan menjalankan aplikasi pemrosesan aliran Apache Flink. Diperlukan peningkatan ke Flink Interpreter Zeppelin untuk mengaktifkan dukungan Flink 1.20. Pekerjaan ini dijadwalkan dengan komunitas Zeppelin. Kami akan memperbarui catatan ini ketika pekerjaan itu selesai. Anda dapat terus menggunakan Flink 1.15 dengan Amazon Managed Service untuk Apache Flink Studio. Untuk informasi selengkapnya, lihat Membuat buku catatan Studio.
Perbaikan bug yang di-backporting
Amazon Managed Service untuk Apache Flink melakukan perbaikan backport dari komunitas Flink untuk masalah kritis. Berikut ini adalah daftar perbaikan bug yang telah kami backport:
| Tautan Apache Flink JIRA | Deskripsi |
|---|---|
| FLINK-35886 |
Perbaikan ini mengatasi masalah yang menyebabkan penghitungan waktu batas waktu kemalasan tanda air yang salah saat subtugas dilakukan. backpressured/blocked |
