Flink SQL Client提交查询后如何从检查点/保存点恢复？能否用flink run -s直接提交？

1. 如何让SQL查询从状态恢复？ #

要让Flink SQL任务从状态恢复，核心是确保任务取消时生成保存点（Savepoint），重启时指定从该保存点恢复，具体操作：

• 取消任务时生成Savepoint：
  • 通过Flink UI取消任务时，选择「Cancel with Savepoint」，指定保存路径（可复用你设置的state.checkpoints.dir路径）；
  • 或用命令行执行：

    ./bin/flink cancel -s file:///tmp/flink-savepoints-directory-from-set/ <job-id>
    

    执行后会返回生成的Savepoint完整路径，比如file:///tmp/flink-savepoints-directory-from-set/savepoint-xxx。
• 重启任务时加载Savepoint：
  在SQL Client中先设置恢复路径，再提交原SQL：

  SET 'execution.savepoint.path' = 'file:///tmp/flink-savepoints-directory-from-set/savepoint-xxx';
  -- 执行你的原SQL语句
  INSERT INTO target_topic SELECT ... FROM source_topic JOIN ...;
  

• 关键注意事项：
  • 重启时表的DDL定义（表名、字段、Kafka主题、序列化配置等）必须和之前完全一致，否则状态无法匹配；
  • 确认状态后端为持久化类型（如FileSystemStateBackend），你当前用文件系统路径，这点符合要求。

2. 是否可以使用flink run -s ...命令直接提交SQL查询，而非打包为Jar包？ #

可以，直接利用Flink自带的SQL Client Jar包即可实现，无需自行打包：

• 把你的SQL查询写入一个文件（比如query.sql）；
• 执行以下命令提交，指定Savepoint路径和SQL文件：

  ./bin/flink run -s <savepoint完整路径> ./lib/flink-sql-client-<版本号>.jar -f /path/to/query.sql
  

  其中flink-sql-client-<版本号>.jar是Flink安装目录下lib文件夹中的SQL Client Jar包，替换成你实际的版本即可。

内容的提问来源于stack exchange，提问作者hitesh