Re: state无法从checkpoint中恢复

2020-07-16 Thread Congxian Qiu
Hi 1 counts 的数据丢失了能否详细描述一下呢?你预期是什么,看到什么现象 2 能否把你关于 counts 的其他代码也贴一下 3. 你的作业是否从 checkpoint 恢复了呢?这个可以从 JM log 来查看 4. 如果你确定是数据有丢失的话,或许你可以使用 state-process-api[1] 看一下是序列化出去有问题,还是 restore 回来有问题 [1] https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/libs/state_processor_api.html Best, Cong

Re: state无法从checkpoint中恢复

2020-07-17 Thread Congxian Qiu
> 发件人: > "user-zh" > < > qcx978132...@gmail.com>; > 发送时间: 2020年7月16日(星期四) 晚上8:16 > 收件人: "user-zh" > 主题: Re: state无法从checkpoint中恢复 > &g