SQL clinet端，checkpoint 恢复执行

Wed, 08 Sep 2021 18:47:54 -0700 

您好：

       版本：flink1.13
        运行： flink sql
        源表： 基于kafka建表
        处理逻辑：简单过滤输出到hive

        问题：
        每1分钟做一次checkpoint，然后由于某原因需要取消任务，再次运行job如何继续从最新的checkpoint继续处理，在客户端设置了参数：
        
execution.savepoint.path=hdfs:///user/flink/checkpoints/68e103c6ec9d8bfe459cb6c329ec696c
        
execution.checkpoint.path=hdfs:///user/flink/checkpoints/68e103c6ec9d8bfe459cb6c329ec696c
     重新 运行后依然是从开始消费处理，未从checkpoint恢复执行

从 Windows 版邮件<https://go.microsoft.com/fwlink/?LinkId=550986>发送

回复