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

Upgrade ke Flink 2.2: Panduan lengkap

Panduan ini memberikan step-by-step petunjuk untuk meningkatkan Layanan Terkelola Amazon Anda untuk aplikasi Apache Flink dari Flink 1.x ke Flink 2.2. Ini adalah peningkatan versi utama dengan perubahan yang melanggar yang memerlukan perencanaan dan pengujian yang cermat.

Prasyarat

Sebelum memulai upgrade Anda:

Memahami jalur migrasi Anda

Pengalaman upgrade Anda bergantung pada kompatibilitas aplikasi Anda dengan Flink 2.2. Memahami jalur ini membantu Anda mempersiapkan dengan tepat dan menetapkan harapan yang realistis.

Jalur 1: Status biner dan aplikasi yang kompatibel

Apa yang diharapkan:

Terbaik untuk: Aplikasi atau aplikasi stateless menggunakan serialisasi yang kompatibel (Avro, skema Protobuf yang kompatibel, tanpa koleksi) POJOs

Jalur 2: Ketidakcocokan biner

Apa yang diharapkan:

Terbaik untuk: Aplikasi yang menggunakan dihapus APIs yang terdeteksi selama startup pekerjaan Flink

Jalur 3: Status aplikasi yang tidak kompatibel

Apa yang diharapkan:

Terbaik untuk: Aplikasi dengan ketidakcocokan serialisasi status (POJOs dengan koleksi, status serial KRYO tertentu)

Tahap 1: Persiapan

Perbarui kode aplikasi

Perbarui kode aplikasi Anda agar kompatibel dengan Flink 2.2:

Unggah kode aplikasi yang diperbarui

Tahap 2: Aktifkan rollback otomatis

Auto-rollback memungkinkan Amazon Managed Service untuk Apache Flink untuk secara otomatis kembali ke versi sebelumnya jika upgrade gagal.

Periksa status rollback otomatis

Konsol Manajemen AWS:

AWS CLI:

aws kinesisanalyticsv2 describe-application \
    --application-name MyApplication \
    --query 'ApplicationDetail.ApplicationConfigurationDescription.ApplicationSystemRollbackConfigurationDescription.RollbackEnabled'

Aktifkan auto-rollback (jika tidak diaktifkan)

aws kinesisanalyticsv2 update-application \
    --application-name MyApplication \
    --current-application-version-id <version-id> \
    --application-configuration-update '{
        "ApplicationSystemRollbackConfigurationUpdate": {
            "RollbackEnabledUpdate": true
        }
    }'

Fase 3: Ambil snapshot (opsional)

Jika snapshot otomatis diaktifkan untuk aplikasi Anda, Anda dapat melewati langkah ini, jika tidak, ambil snapshot aplikasi Anda untuk menyimpan status aplikasi Anda sebelum memutakhirkan.

Ambil snapshot dari menjalankan aplikasi

Konsol Manajemen AWS:

AWS CLI:

aws kinesisanalyticsv2 create-application-snapshot \
    --application-name MyApplication \
    --snapshot-name pre-flink-2.2-upgrade

Verifikasi pembuatan snapshot

aws kinesisanalyticsv2 describe-application-snapshot \
    --application-name MyApplication \
    --snapshot-name pre-flink-2.2-upgrade

Tunggu sampai SnapshotStatus READY sebelum melanjutkan.

Tahap 4: Tingkatkan aplikasi

Anda dapat meningkatkan aplikasi Flink Anda dengan menggunakan UpdateApplicationtindakan.

Anda dapat memanggil UpdateApplication API dengan berbagai cara:

Anda dapat melakukan pemutakhiran saat aplikasi dalam RUNNING keadaan atau saat aplikasi dihentikan dalam READY status. Amazon Managed Service untuk Apache Flink memvalidasi kompatibilitas antara versi runtime asli dan versi runtime target. Pemeriksaan kompatibilitas ini berjalan saat Anda melakukan UpdateApplication saat dalam RUNNING status atau berikutnya StartApplication jika Anda memutakhirkan saat dalam READY status.

Tingkatkan dari status RUNNING

aws kinesisanalyticsv2 update-application \
    --application-name MyApplication \
    --current-application-version-id <version-id> \
    --runtime-environment-update FLINK-2_2 \
    --application-configuration-update '{
        "ApplicationCodeConfigurationUpdate": {
            "CodeContentUpdate": {
                "S3ContentLocationUpdate": {
                    "FileKeyUpdate": "my-app-flink-2.2.jar"
                }
            }
        }
    }'

Tingkatkan dari status READY

aws kinesisanalyticsv2 update-application \
    --application-name MyApplication \
    --current-application-version-id <version-id> \
    --runtime-environment-update FLINK-2_2 \
    --application-configuration-update '{
        "ApplicationCodeConfigurationUpdate": {
            "CodeContentUpdate": {
                "S3ContentLocationUpdate": {
                    "FileKeyUpdate": "my-app-flink-2.2.jar"
                }
            }
        }
    }'

Tahap 5: Memantau peningkatan

Pemeriksaan kompatibilitas

Pantau kesehatan aplikasi

Status aplikasi:

Selain itu, pantau metrik ini di CloudWatch:

Mulai ulang metrik:

Metrik pos pemeriksaan:

Fase 6: Validasi perilaku aplikasi

Setelah aplikasi berjalan di Flink 2.2:

Validasi fungsional

Validasi kinerja

Jalankan selama 24+ jam

Biarkan aplikasi berjalan setidaknya selama 24 jam dalam produksi untuk memastikan:

Fase 7: Prosedur rollback

Jika pemutakhiran gagal atau aplikasi berjalan tetapi tidak sehat, putar kembali ke versi sebelumnya.

Rollback otomatis

Jika auto-rollback diaktifkan dan upgrade gagal selama startup, Amazon Managed Service untuk Apache Flink otomatis kembali ke versi sebelumnya.

Rollback manual

Jika aplikasi berjalan tetapi tidak sehat, gunakan RollbackApplication API:

Konsol Manajemen AWS:

AWS CLI:

aws kinesisanalyticsv2 rollback-application \
    --application-name MyApplication \
    --current-application-version-id <version-id>

Apa yang terjadi selama rollback:

Langkah selanjutnya

Untuk pertanyaan atau masalah selama upgrade, lihat Memecahkan Masalah Layanan Terkelola untuk Apache Flink atau hubungi AWS Support.