Re: Data is lost in the ListState

Thanks David, it’s clear now. In my case, the x2 will be recovered by the last checkpoint if it was processed and wait few seconds to be checkpointed Or my source can be rewind and it will replay the x2. > 2022年7月12日 09:10，David Anderson 写道： > > This is, in fact, the expected behavior. Let

Re: Flink 1.14.4 HybridSource consumes lots of CPU resources

Hi Mason, I upload the code and resource files to AwesomeArthurLi/quickstart: quickstart (github.com) <https://github.com/AwesomeArthurLi/quickstart>, may it will help you reproduce the issue. BR. Arthur Li > 2022年5月3日 15:48，Mason Chen 写道： > > Hi Arthur, > > C

Flink 1.14.4 HybridSource consumes lots of CPU resources

Hi all, the Hybrid Source | Apache Flink is one of new features of Flink 1.14.x, but one problem is it takes over 700% CPU which is almost 5 times than these two splits. My En