手动停止再恢复的话需要启动时通过 (-s 上一次checkpoint的mate路径)进行恢复 https://ci.apache.org/projects/flink/flink-docs-release-1.11/ops/state/check points.html#resuming-from-a-retained-checkpoint -----邮件原件----- 发件人: 凌天荣 <466792...@qq.com> 发送时间: 2020年9月8日 15:50 收件人: user-zh <user-zh@flink.apache.org> 主题: flink-sql 1.11版本都还没完全支持checkpoint吗
代码里设置了enableCheckpointing，任务停掉后，重启，还是没能消费停掉期间的数 据，也就是checkpoint没生效
