再启动服务的时候 需要指定checkpoint回复地址,你这里只是指定了做checkpint地址
在 2020-09-03 16:03:41,"sun" <1392427...@qq.com> 写道:
>你好,我有2个问题
>
>1:每次重启服务,checkpoint的目录中chk- 总是从chk-1开始,chk-2 ,没有从上次的编号开始
>
>2:重启服务后,没有从checkpoint中恢复state的数据
>
>下面是我的配置,我是在本地调试的,单机
>
>
>
>final StreamExecutionEnvironment s
Hi
从 retain checkpoint 恢复可以参考文档[1]
[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.11/zh/ops/state/checkpoints.html#%E4%BB%8E%E4%BF%9D%E7%95%99%E7%9A%84-checkpoint-%E4%B8%AD%E6%81%A2%E5%A4%8D%E7%8A%B6%E6%80%81
Best,
Congxian
sun <1392427...@qq.com> 于2020年9月3日周四 下午4:14写道:
> 你好,
/opt/flink/bin/flink run -d -s /opt/flink/savepoints -c
com.xxx.flink.ohlc.kafka.OrderTickCandleView
/home/service-ohlc-*-SNAPSHOT.jar
在启动job时,已经指定这个目录,但会报以下错,
Caused by: org.apache.flink.runtime.client.JobExecutionException: Could not
instantiate JobManager.
at
org.apache.flink.runtime.di
Hi
从报错看,你知道的是一个目录,这个目录下面没有 _metadata 文件,这不是一个完整的 checkpoint/savepoint
因此不能用于恢复
Best,
Congxian
marble.zh...@coinflex.com.INVALID
于2020年10月27日周二 下午4:06写道:
> /opt/flink/bin/flink run -d -s /opt/flink/savepoints -c
> com.xxx.flink.ohlc.kafka.OrderTickCandleView
> /home/service-ohlc-*-SNAPSHOT.ja