CheckpointConfiguration - Amazon Managed Service for Apache Flink (先前為 Amazon Kinesis Data Analytics for Apache Flink)

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

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 的詳細資訊,請參閱下列內容: