flink
flink copied to clipboard
[FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint…
…Config` and move it to flink-core.
What is the purpose of the change
In FLIP-406 we want to merge all options from ExecutionCheckpointingOptions into CheckpointingOptions. We need to split ExecutionCheckpointingOptions
from CheckpointConfig
and move it to flink-core. This PR introduces a new ExecutionCheckpointingOptions
in flink-core and deprecates the old CheckpointConfig.ExecutionCheckpointingOptions
and corresponding user-facing API.
Verifying this change
- introduce a new
ExecutionCheckpointingOptions
in flink-core, providing new APIs. - deprecate the old
CheckpointConfig.ExecutionCheckpointingOptions
inflink-streaming-java
as well as the APIs.
Does this pull request potentially affect one of the following parts:
- Dependencies (does it add or upgrade a dependency): (yes / no)
- The public API, i.e., is any changed class annotated with
@Public(Evolving)
: (yes / no) - The serializers: (yes / no / don't know)
- The runtime per-record code paths (performance sensitive): (yes / no / don't know)
- Anything that affects deployment or recovery: JobManager (and its components), Checkpointing, Kubernetes/Yarn, ZooKeeper: (yes / no / don't know)
- The S3 file system connector: (yes / no / don't know)
Documentation
- Does this pull request introduce a new feature? (yes / no)
- If yes, how is the feature documented? (not applicable / docs / JavaDocs / not documented)
CI report:
- 1927210608564f68ded88588081908674493ed42 UNKNOWN
- 9cf67cdf47f2230c0fc7c05ce0b2011a7ce3b7c4 Azure: SUCCESS
Bot commands
The @flinkbot bot supports the following commands:-
@flinkbot run azure
re-run the last Azure build
@Zakelly Please help me take a look at this PR to see if it meets the requirements.
@flinkbot run azure
@Zakelly The code has been modified, please take a look again
@flinkbot run azure
@flinkbot run azure
@flinkbot run azure
@Zakelly @masteryhx The code has been adjusted, please help me take a look again.
@masteryhx Hi,this pr blocks another pr. Can you help me take a look? By the way, this change caused a python test error. Since I don’t have much experience in using python, I modified it several times and failed the test.
@masteryhx Hi,this pr blocks another pr. Can you help me take a look? By the way, this change caused a python test error. Since I don’t have much experience in using python, I modified it several times and failed the test.
It seems the CI pipeline failed to trigger test for your last commit. How about re-commit your last commit and force push to trigger the CI?
@flinkbot run azure
@flinkbot run azure
@Zakelly @masteryhx What further discussions are needed on the modification of the python part? This PR has been on hold for some time.
@spoon-lz sorry for the late reply. I agreed with @masteryhx that we'd better create another new class and deprecate the old one in python.
@flinkbot run azure
@Zakelly @masteryhx A new ExternalizedCheckpointRetention.py
is created, the old one is marked as deprecated, and a separate commit for the python part is split.
@flinkbot run azure
@Zakelly Flink-ci has passed
I modified the commit message and remove those 'cherry-picked from xxxxx'. Already merged into master.