CheckpointConfiguration - 阿帕奇 Flink 的 Amazon 託管服務(以前為阿帕奇 Flink 的 Amazon Kinesis Data Analytics)

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

CheckpointConfiguration

描述應用程式的檢查點組態。檢查點是針對容錯能力保留應用程式狀態的程序。如需詳細資訊,請參閱 Apache Flink Documentation (《Apache Flink 文件》) 中的 Checkpoints for Fault Tolerance (容錯檢查點)。

目錄

ConfigurationType

描述應用程式是否針對 Apache Flink 的預設檢查點行為使用「受管理服務」。您必須將此屬性設定為 CUSTOM,才能設定 CheckpointingEnabledCheckpointIntervalMinPauseBetweenCheckpoints 參數。

注意

如果此值設為 DEFAULT,即使使用 API 或在應用程式碼中將它們設為其他值,應用程式仍會使用下列值:

  • CheckpointingEnabled:

  • CheckpointInterval: 60000

  • MinPauseBetweenCheckpoints: 5000

類型:字串

有效值:DEFAULT | CUSTOM

必要:是

CheckpointingEnabled

描述是否為 Apache Flink 應用程式的受管理服務啟用檢查點。

注意

如果 CheckpointConfiguration.ConfigurationTypeDEFAULT,即使使用此 API 或在應用程式碼中將 CheckpointingEnabled 值設定為另一個值,應用程式仍會使用 true

類型:布林值

必要:否

CheckpointInterval

描述檢查點操作之間的間隔 (毫秒)。

注意

如果 CheckpointConfiguration.ConfigurationTypeDEFAULT,即便使用此 API 或在應用程式碼中將 CheckpointInterval 值設定為另一個值,應用程式仍會使用 60000。

類型:Long

有效範圍:最小值為 1。

必要:否

MinPauseBetweenCheckpoints

描述檢查點操作完成後,新的檢查點操作可以開始的最短時間 (毫秒)。如果檢查點操作時間超過 CheckpointInterval,應用程式就會執行後續的檢查點操作。如需詳細資訊,請參閱 Apache Flink Documentation (《Apache Flink 文件》) 中的 Tuning Checkpointing (調整檢查點)。

注意

如果 CheckpointConfiguration.ConfigurationTypeDEFAULT,即使使用此 API 或在應用程式碼中設定 MinPauseBetweenCheckpoints 值,應用程式仍會使用 5000。

類型:Long

有效範圍:最小值為 0。

必要:否

另請參閱

如需在其中一個特定語言 AWS SDK 中使用此 API 的詳細資訊,請參閱下列內容: