Hi Averell, You need to understand that Flink reflects the recovery of the state, not the recovery of the record. Of course, sometimes your record is state, but sometimes the intermediate result of your record is the state. It depends on your business logic and your operators.
Thanks, vino. Averell <lvhu...@gmail.com> 于2018年8月8日周三 下午1:17写道： > Thank you Fabian. > "/In either case, some record will be read twice but if reading position > can > be reset, you can still have exactly-once state consistency because the > state is reset as well./" > I do not quite understand this statement. If I have read 30 lines from the > checkpoint and sent those 30 records to the next operator, then when the > streaming is recovered - resumed from the last checkpoint, the subsequent > operator would receive those 30 lines again, am I right? > > Thanks! > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ >
