Amazon Managed Service untuk Apache Flink sebelumnya dikenal sebagai Amazon Kinesis Data Analytics untuk Apache Flink.

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

Kelola cadangan aplikasi menggunakan snapshot

Snapshot adalah Managed Service untuk implementasi Apache Flink dari Apache Flink Savepoint. Snapshot adalah cadangan status aplikasi yang dipicu, dibuat, dan dikelola pengguna atau layanan. Untuk informasi tentang Apache Flink Savepoints, lihat Savepoints di Dokumentasi Apache Flink. Menggunakan snapshot, Anda dapat me-restart aplikasi dari snapshot tertentu dari status aplikasi.

Di Managed Service for Apache Flink, Anda mengelola snapshot menggunakan tindakan berikut: API

Untuk batas per aplikasi pada jumlah snapshot, lihat Layanan Terkelola untuk kuota notebook Apache Flink dan Studio. Jika aplikasi Anda mencapai batas pada snapshot, lalu secara manual membuat snapshot gagal dengan LimitExceededException.

Layanan Terkelola untuk Apache Flink tidak pernah menghapus snapshot. Anda harus secara manual menghapus snapshot menggunakan tindakan DeleteApplicationSnapshot.

Untuk memuat snapshot status aplikasi tersimpan saat memulai aplikasi, gunakan parameter ApplicationRestoreConfiguration dari StartApplication atau tindakan UpdateApplication.

Kelola pembuatan snapshot otomatis

Jika SnapshotsEnabled diatur ke true dalam untuk aplikasi, Managed Service ApplicationSnapshotConfigurationfor Apache Flink secara otomatis membuat dan menggunakan snapshot saat aplikasi diperbarui, diskalakan, atau dihentikan untuk menyediakan semantik pemrosesan yang tepat sekali.

Snapshot yang dibuat secara otomatis memiliki kualitas berikut:

Pulihkan dari snapshot yang berisi data status yang tidak kompatibel

Karena snapshot berisi informasi tentang operator, memulihkan data status dari snapshot untuk operator yang telah berubah sejak versi aplikasi sebelumnya mungkin memiliki hasil yang tak terduga. Aplikasi akan gagal jika mencoba memulihkan data status dari snapshot yang tidak sesuai dengan operator saat ini. Aplikasi yang gagal akan terhenti di status STOPPING atau UPDATING.

Untuk memungkinkan aplikasi memulihkan dari snapshot yang berisi data status yang tidak kompatibel, atur AllowNonRestoredState parameter FlinkRunConfigurationuntuk true menggunakan tindakan. UpdateApplication

Anda akan melihat perilaku berikut ketika aplikasi dipulihkan dari snapshot usang:

Jika Anda perlu melanjutkan aplikasi yang tidak kompatibel dengan data savepoint yang ada, sebaiknya Anda melewatkan pemulihan dari snapshot dengan menyetel ApplicationRestoreType parameter tindakan ke. StartApplicationSKIP_RESTORE_FROM_SNAPSHOT

Untuk informasi selengkapnya tentang cara Apache Flink menangai data status yang tidak kompatibel, lihat Evolusi Skema Status di Dokumentasi Apache Flink.

Tinjau contoh snapshot API

Bagian ini mencakup contoh permintaan API tindakan untuk menggunakan snapshot dengan aplikasi. Untuk informasi tentang cara menggunakan JSON file untuk masukan API tindakan, lihatLayanan Terkelola untuk kode contoh Apache Flink API.

Aktifkan snapshot untuk aplikasi

Contoh permintaan untuk tindakan UpdateApplication berikut mengaktifkan snapshot untuk aplikasi:

{
   "ApplicationName": "MyApplication",
   "CurrentApplicationVersionId": 1,
   "ApplicationConfigurationUpdate": { 
      "ApplicationSnapshotConfigurationUpdate": { 
         "SnapshotsEnabledUpdate": "true"
       }
    }
}

Buat snapshot

Contoh permintaan untuk tindakan CreateApplicationSnapshot berikut membuat snapshot dari status aplikasi saat ini:

{
   "ApplicationName": "MyApplication",
   "SnapshotName": "MyCustomSnapshot"
}

Buat daftar snapshot untuk aplikasi

Contoh permintaan untuk tindakan ListApplicationSnapshots berikut mencantumkan 50 snapshot pertama untuk status aplikasi saat ini:

{
   "ApplicationName": "MyApplication",
   "Limit": 50
}

Rincian daftar untuk snapshot aplikasi

Contoh permintaan berikut untuk tindakan DescribeApplicationSnapshot mencantumkan detail untuk snapshot aplikasi tertentu:

{
   "ApplicationName": "MyApplication",
   "SnapshotName": "MyCustomSnapshot"
}

Menghapus snapshot

Contoh permintaan berikut untuk tindakan DeleteApplicationSnapshot menghapus snapshot yang disimpan sebelumnya. Anda bisa mendapatkan nilai SnapshotCreationTimestamp menggunakan ListApplicationSnapshots atau DeleteApplicationSnapshot:

{
   "ApplicationName": "MyApplication",
   "SnapshotName": "MyCustomSnapshot",
   "SnapshotCreationTimestamp": 12345678901.0,
}

Mulai ulang aplikasi menggunakan snapshot bernama

Contoh permintaan berikut untuk tindakan StartApplication memulai aplikasi menggunakan status yang disimpan dari snapshot tertentu:

{
   "ApplicationName": "MyApplication",
   "RunConfiguration": { 
      "ApplicationRestoreConfiguration": { 
         "ApplicationRestoreType": "RESTORE_FROM_CUSTOM_SNAPSHOT",
         "SnapshotName": "MyCustomSnapshot"
      }
   }
}

Mulai ulang aplikasi menggunakan snapshot terbaru

Contoh permintaan berikut untuk tindakan StartApplication memulai aplikasi menggunakan snapshot terbaru:

{
   "ApplicationName": "MyApplication",
   "RunConfiguration": { 
      "ApplicationRestoreConfiguration": { 
         "ApplicationRestoreType": "RESTORE_FROM_LATEST_SNAPSHOT"
      }
   }
}

Mulai ulang aplikasi tanpa snapshot

Contoh permintaan berikut untuk tindakan StartApplication memulai aplikasi tanpa memuat status aplikasi, bahkan jika snapshot tersedia:

{
   "ApplicationName": "MyApplication",
   "RunConfiguration": { 
      "ApplicationRestoreConfiguration": { 
         "ApplicationRestoreType": "SKIP_RESTORE_FROM_SNAPSHOT"
      }
   }
}