Flink 状态检查点保留数量配置参数：state.checkpoints.num-retained

`state.checkpoints.num-retained` 是 Apache Flink 的配置参数，用于指定在执行检查点时要保留的最大检查点数量。\n\n在 Flink 中，检查点是一种容错机制，用于在发生故障时恢复应用程序的状态。当 Flink 执行检查点时，它会将应用程序的状态保存到持久化存储中（例如分布式文件系统），以便在发生故障时可以恢复。`state.checkpoints.num-retained` 参数用于控制要保留的检查点数量。\n\n默认情况下，Flink 会保留所有的检查点。但是，如果应用程序的状态很大，保留所有检查点可能会占用大量的存储空间。因此，可以使用 `state.checkpoints.num-retained` 参数来限制要保留的检查点的数量。例如，可以将该参数设置为 3，表示只保留最近的 3 个检查点，而旧的检查点将被删除。\n\n该参数可以在 Flink 的配置文件（flink-conf.yaml）中进行配置，也可以通过 Flink 的命令行选项进行配置。例如，在命令行中可以使用以下选项设置 `state.checkpoints.num-retained` 参数的值：\n\n\n./bin/flink run -Dstate.checkpoints.num-retained=3 your_program.jar\n\n\n上述命令将设置 `state.checkpoints.num-retained` 参数的值为 3，并执行您的应用程序。