本文為英文版的機器翻譯版本，如內容有任何歧義或不一致之處，概以英文版為準。

啟用檢查點

您可以使用環境設定來啟用檢查點。如需檢查點的相關資訊，請參閱 Managed Service for Apache Flink 開發人員指南中的容錯。

設定檢查點間隔

以下 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"
)