Re:无法从checkpoint中恢复state

2020-09-03 Thread 程龙
再启动服务的时候 需要指定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

Re: 无法从checkpoint中恢复state

2020-09-03 Thread Congxian Qiu
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写道： > 你好，

Re: Re:无法从checkpoint中恢复state

2020-10-27 Thread marble.zh...@coinflex.com.INVALID
/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

Re: Re:无法从checkpoint中恢复state

2020-10-27 Thread Congxian Qiu
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