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.

Aktifkan pos pemeriksaan

Anda mengaktifkan checkpointing menggunakan pengaturan lingkungan. Untuk informasi tentang checkpointing, lihat Toleransi Kesalahan di Managed Service for Apache Flink Developer Guide.

Mengatur interval checkpointing

Contoh kode Scala berikut mengatur interval titik pemeriksaan aplikasi Anda ke satu menit:

// start a checkpoint every 1 minute
stenv.enableCheckpointing(60000)

Contoh kode Phyton berikut mengatur interval titik pemeriksaan aplikasi Anda ke satu menit:

st_env.get_config().get_configuration().set_string(
    "execution.checkpointing.interval", "1min"
)

Mengatur jenis checkpointing

Contoh kode Scala berikut mengatur mode titik pemeriksaan aplikasi Anda ke EXACTLY_ONCE (default):

// set mode to exactly-once (this is the default)
stenv.getCheckpointConfig.setCheckpointingMode(CheckpointingMode.EXACTLY_ONCE)

Contoh kode Phyton berikut mengatur mode titik pemeriksaan aplikasi Anda ke EXACTLY_ONCE (default):

st_env.get_config().get_configuration().set_string(
    "execution.checkpointing.mode", "EXACTLY_ONCE"
)