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

Memutakhirkan ke Flink 2.2: Panduan lengkap

Panduan ini memberikan petunjuk langkah demi langkah untuk meningkatkan aplikasi Amazon Managed Service for Apache Flink dari Flink 1.x ke Flink 2.2. Ini adalah peningkatan versi utama dengan perubahan besar yang memerlukan perencanaan dan pengujian yang cermat.

Prasyarat

Sebelum memulai upgrade Anda:

Memahami jalur migrasi Anda

Pengalaman upgrade Anda tergantung 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 tanpa status menggunakan serialisasi yang kompatibel (Avro, skema Protobuf yang kompatibel, POJO tanpa koleksi)

Jalur 2: Ketidakcocokan biner

Apa yang diharapkan:

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

Jalur 3: Status aplikasi yang tidak kompatibel

Apa yang diharapkan:

Terbaik untuk: Aplikasi dengan inkompatibilitas serialisasi status (POJO dengan koleksi, status tertentu) Kryo-serialized

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 for Apache Flink untuk secara otomatis kembali ke versi sebelumnya jika peningkatan gagal.

Periksa status pengembalian otomatis

Konsol Manajemen AWS:

AWS CLI:

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

Aktifkan rollback otomatis (jika tidak diaktifkan)

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

Tahap 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 aplikasi yang sedang berjalan

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: Upgrade aplikasi

Anda dapat meningkatkan aplikasi Flink Anda dengan menggunakan UpdateApplication tindakan.

Anda dapat memanggil UpdateApplication API dengan berbagai cara:

Anda dapat melakukan upgrade saat aplikasi dalam RUNNING keadaan atau saat aplikasi dihentikan dalam READY keadaan. Amazon Managed Service for Apache Flink memvalidasi kompatibilitas antara versi runtime asli dan versi runtime target. Pemeriksaan kompatibilitas ini berjalan UpdateApplication saat Anda melakukan 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"
                }
            }
        }
    }'

Upgrade 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: Pembaruan monitor

Pemeriksaan kompatibilitas

Memantau kesehatan aplikasi

Status aplikasi:

Selain itu, pantau metrik ini di CloudWatch:

Mulai ulang metrik:

Metrik pos pemeriksaan:

Tahap 6: Validasi perilaku aplikasi

Setelah aplikasi berjalan di Flink 2.2:

Validasi fungsional

Validasi kinerja

Jalankan selama 24+ jam

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

Tahap 7: Prosedur Rollback

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

Kembalikan otomatis

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

Pengembalian 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 peningkatan, lihat Memecahkan Masalah Layanan Terkelola untuk Apache Flink atau hubungi AWS Dukungan.