如何自动查找最新的savepoint

要自动查找最新的 savepoint，可以使用以下步骤：

1. 首先需要设置 Flink 作业的 savepoint 存储路径。可以在 Flink 的配置文件中设置 `state.savepoints.dir` 属性，或在提交任务时通过 `--fromSavepoint` 参数指定。

2. 在脚本中，使用 `find` 命令查找指定目录下最新的 savepoint 文件。可以按照 savepoint 文件名称中的时间戳进行排序，找到最新的那个。示例命令如下：

   savepoint_dir=/path/to/savepoint/dir
   latest_savepoint=$(find "$savepoint_dir" -name "savepoint-*" | sort -r | head -n 1)

这里假设 savepoint 文件的名称为 `savepoint-xxxxxx`，其中 `xxxxxx` 是时间戳。

3. 将最新的 savepoint 路径传递给 Flink 任务启动脚本，例如：

   flink run -s "$latest_savepoint" ...

整个脚本示例如下：

#!/bin/bash

# 设置 savepoint 目录
savepoint_dir=/path/to/savepoint/dir

# 查找最新的 savepoint 文件
latest_savepoint=$(find "$savepoint_dir" -name "savepoint-*" | sort -r | head -n 1)

# 启动 Flink 任务
flink run -s "$latest_savepoint" ...

这样，每次运行脚本时，都会自动查找最新的 savepoint 文件，并将其传递给 Flink 任务启动脚本。