Hi！
execution.checkpoint.path 这个参数不存在，只有
execution.savepoint.path。另外是通过什么方式设置参数的呢？是写在 flink-conf.yaml 里吗？还是通过 SET 语句？
outlook_3e5704ab57282...@outlook.com
于2021年9月9日周四 上午9:47写道：
>
> 您好：
>
>版本：flink1.13
> 运行： flink sql
> 源表： 基于kafka建表
> 处理逻辑：简单过滤输出到hive
>
>
您好：
版本：flink1.13
运行： flink sql
源表： 基于kafka建表
处理逻辑：简单过滤输出到hive
问题：
每1分钟做一次checkpoint，然后由于某原因需要取消任务，再次运行job如何继续从最新的checkpoint继续处理，在客户端设置了参数：
execution.savepoint.path=hdfs:///user/flink/checkpoints/68e103c6ec9d8bfe459cb6c329ec696c
您好：
版本：flink1.13
运行： flink sql
源表： 基于kafka建表
处理逻辑：简单过滤输出到hive
问题：
每1分钟做一次checkpoint，然后由于某原因需要取消任务，再次运行job如何继续从最新的checkpoint继续处理，在客户端设置了参数：
execution.savepoint.path=hdfs:///user/flink/checkpoints/68e103c6ec9d8bfe459cb6c329ec696c
