Page History

The finish() method is tied to the lifecycle of an Operator and it is NOT tied to the lifecycle of State. It is possible that after recovery a state created after calling finish() might be restored to an operator that will receive more records. The operator implementation must be prepared for that.

In particular it is generally not safe to write a finished flag into the state and check that you do not receive records if the flag is set.