Re: Error while deserializing the element

2021-08-26 Thread JING ZHANG
My previous response in mail list was too brief, sorry about that. For the use of config 'state.backend.rocksdb.timer-service.factory: HEAP', I would like to add some information. Please correct me if anything is wrong. 1. The configure could help to avoid the EOF exception when recover rock

Re: Error while deserializing the element

2021-08-19 Thread JING ZHANG
Hi Vijay, Yun, I've created a JIRA https://issues.apache.org/jira/browse/FLINK-23886 to track this. Best, JING ZHANG JING ZHANG 于2021年8月20日周五 下午1:19写道: > Hi Vijay, > I have encountered the same problem several times in online production > Flink jobs, but I have not found the root cause of the e

Re: Error while deserializing the element

2021-08-19 Thread JING ZHANG
Hi Vijay, I have encountered the same problem several times in online production Flink jobs, but I have not found the root cause of the exception yet. We have walk around the exception by adding the following parameter, hope it could help you. state.backend.rocksdb.timer-service.factory: HEAP I wo