search

DTStack / flinkStreamSQL

基于开源的flink，对其实时sql进行扩展；主要实现了流与维表的join，支持原生flink SQL所有的语法
Apache License 2.0
2.02k stars 923 forks source link

flinkstreamsql kafka任务，开启checkpoint，如果我手动杀死任务，如何从指定的最后一次保存的checkpoint启动任务 #428

Open xyls82 opened 3 years ago

xyls82 commented 3 years ago

希望大佬们能回复一下

xyls82 commented 3 years ago

flink 任务可以 run 时 -s 指定最后一次 checkpoint 路径，这个 flinkstreamsql 如何制定？？

a49a commented 3 years ago

文档里有个选项的，你启动的时候指定savePointPath。看下文档里的参数配置。