チェックポイントを有効にする - Managed Service for Apache Flink
チェックポイント間隔を設定するチェックポイントタイプを設定する

Amazon Managed Service for Apache Flink は、以前は Amazon Kinesis Data Analytics for Apache Flink と呼ばれていました。

翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

チェックポイントを有効にする

環境設定を使ってチェックポイント機能を有効にします。チェックポイント機能の詳細については、「Apache Flink 用 Managed Service デベロッパーガイド」の「フォールトトレランス」を参照してください。

チェックポイント間隔を設定する

次の Scala コード例では、アプリケーションのチェックポイント間隔を 1 分に設定しています。

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

次の Python コード例では、アプリケーションのチェックポイント間隔を 1 分に設定しています。

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

チェックポイントタイプを設定する

次の Scala コードの例では、アプリケーションのチェックポイントモードを EXACTLY_ONCE (デフォルト) に設定しています。

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

次の Python コードの例では、アプリケーションのチェックポイントモードを EXACTLY_ONCE (デフォルト) に設定しています。

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