gaoyunhaii opened a new pull request #14754:
URL: https://github.com/apache/flink/pull/14754
## What is the purpose of the change
Stores the information of whether an operator is fully finished into the
checkpoint metadata.
To not have to introduce a new version of checkpoint metadata and due to a
fully finished operator state always has an empty states, we could stores a
special content for the operator state to indicate that the operator is fully
finished.
## Brief change log
- 37484933592e8b5a4f5cf83425ac0b7b612c7480 allows set / get fully finished
flag for operator state, and marked fully finished operators according to the
checkpoint brief computed.
## Verifying this change
This change added unit tests about set and get fully finished flag, and
serialization / deserialization of the operator states marked as fully finished.
## Does this pull request potentially affect one of the following parts:
- Dependencies (does it add or upgrade a dependency): **no**
- The public API, i.e., is any changed class annotated with
`@Public(Evolving)`: **no**
- The serializers: **no**
- The runtime per-record code paths (performance sensitive): **no**
- Anything that affects deployment or recovery: JobManager (and its
components), Checkpointing, Kubernetes/Yarn/Mesos, ZooKeeper: **no**
- The S3 file system connector: **no**
## Documentation
- Does this pull request introduce a new feature? **no**
- If yes, how is the feature documented? **not applicable**
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
