在 Kinesis Data Analytics for Apache Flink - Amazon Kinesis Data Analytics
配置检查点检查点 API 示例
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅 中国的 Amazon Web Services 服务入门 (PDF)。

本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

在 Kinesis Data Analytics for Apache Flink

Checkpoint是用于在适用于 Apache Flink 的 Amazon Kinesis Data Analytics 中实现容错的方法。检查点是正在运行的应用程序的 up-to-date 备份，用于从意外的应用程序中断或故障转移中立即恢复。

有关 Apache Flink 应用程序中检查点的详细信息，请参阅 Apache Flink 文档中的检查点。

快照 是手动创建和管理的应用程序状态备份。通过使用快照，您可以调用 UpdateApplication 以将应用程序还原到以前的状态。有关更多信息，请参阅使用快照管理应用程序备份：

如果为应用程序启用了检查点，该服务将创建应用程序数据备份，并在应用程序意外重新启动时加载该备份以提供容错功能。这些意外的应用程序重新启动可能是由意外的作业重新启动、实例故障等引起的。这会在这些重新启动期间为应用程序提供与无故障执行相同的语义。

如果为应用程序启用了快照并使用应用程序的快照进行配置 ApplicationRestoreConfiguration，则该服务在应用程序更新期间或与服务相关的扩展或维护期间仅提供一次性处理语义。

在 Kinesis Data Analytics for Apache Flink

您可以配置应用程序的检查点行为。您可以定义它是否永久保存检查点状态、将其状态保存到检查点的频率以及一个检查点操作结束到另一个检查点操作开始之间的最小间隔。

您可以使用 CreateApplication 或 UpdateApplication API 操作配置以下设置：

  • CheckpointingEnabled— 表示是否在应用程序中启用了检查点。

  • CheckpointInterval— 包含检查点（持久性）操作之间的时间（以毫秒为单位）。

  • ConfigurationType— 将此值设置DEFAULT为以使用默认的检查点行为。将该值设置为 CUSTOM 以配置其他值。

    注意

    默认检查点行为如下所示：

    • CheckpointingEnabled: 真的

    • CheckpointInterval: 60000

    • MinPauseBetweenCheckpoints: 5000

    如果此值设置ConfigurationType为DEFAULT，则将使用前面的值，即使通过使用Amazon Command Line Interface、或通过使用应用程序代码中的值将其设置为其他值也是如此。

    注意

    对于 Flink 1.15 以后，适用于 Apache Flink 的 Kinesis Data Analytics 将在自动创建快照stop-with-savepoint期间使用，即应用程序更新、缩放或停止。

  • MinPauseBetweenCheckpoints— 一个检查点操作结束与另一个检查点操作开始之间的最短时间（以毫秒为单位）。如果设置该值，则可以防止应用程序在检查点操作所花的时间超过 CheckpointInterval 时继续执行检查点操作。

检查点 API 示例

本节包含为应用程序配置检查点的 API 操作的示例请求。有关如何将 JSON 文件用于 API 操作输入的信息，请参阅 Kinesis Data Analytics。

为新应用程序配置检查点

CreateApplication 操作的以下示例请求在您创建应用程序时配置检查点：

{
   "ApplicationName": "MyApplication",
   "RuntimeEnvironment":"FLINK-1_15",
   "ServiceExecutionRole":"arn:aws:iam::123456789123:role/myrole",
   "ApplicationConfiguration": { 
      "ApplicationCodeConfiguration":{
      "CodeContent":{
        "S3ContentLocation":{
          "BucketARN":"arn:aws:s3:::mybucket",
          "FileKey":"myflink.jar",
          "ObjectVersion":"AbCdEfGhIjKlMnOpQrStUvWxYz12345"
        }
      },
      "FlinkApplicationConfiguration": { 
         "CheckpointConfiguration": { 
            "CheckpointingEnabled": "true",
            "CheckpointInterval": 20000,
            "ConfigurationType": "CUSTOM",
            "MinPauseBetweenCheckpoints": 10000
         }
      }
}

为新应用程序禁用检查点

CreateApplication 操作的以下示例请求在您创建应用程序时禁用检查点：

{
   "ApplicationName": "MyApplication",
   "RuntimeEnvironment":"FLINK-1_15",
   "ServiceExecutionRole":"arn:aws:iam::123456789123:role/myrole",
   "ApplicationConfiguration": { 
      "ApplicationCodeConfiguration":{
      "CodeContent":{
        "S3ContentLocation":{
          "BucketARN":"arn:aws:s3:::mybucket",
          "FileKey":"myflink.jar",
          "ObjectVersion":"AbCdEfGhIjKlMnOpQrStUvWxYz12345"
        }
      },
      "FlinkApplicationConfiguration": { 
         "CheckpointConfiguration": { 
            "CheckpointingEnabled": "false"
         }
      }
}

为现有应用程序配置检查点

UpdateApplication 操作的以下示例请求为现有应用程序配置检查点：

{
   "ApplicationName": "MyApplication",
   "ApplicationConfigurationUpdate": { 
      "FlinkApplicationConfigurationUpdate": { 
         "CheckpointConfigurationUpdate": { 
            "CheckpointingEnabledUpdate": true,
            "CheckpointIntervalUpdate": 20000,
            "ConfigurationTypeUpdate": "CUSTOM",
            "MinPauseBetweenCheckpointsUpdate": 10000
         }
      }
   }
}

为现有应用程序禁用检查点

UpdateApplication 操作的以下示例请求为现有应用程序禁用检查点：

{
   "ApplicationName": "MyApplication",
   "ApplicationConfigurationUpdate": { 
      "FlinkApplicationConfigurationUpdate": { 
         "CheckpointConfigurationUpdate": { 
            "CheckpointingEnabledUpdate": false,
            "CheckpointIntervalUpdate": 20000,
            "ConfigurationTypeUpdate": "CUSTOM",
            "MinPauseBetweenCheckpointsUpdate": 10000
         }
      }
   }
}