New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[FLINK-26560][StateBackends] Make the threshold of the overlap fraction of incremental restoring configurable #19106
Conversation
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks for creating this PR. PTAL.
...rc/main/java/org/apache/flink/contrib/streaming/state/RocksDBIncrementalCheckpointUtils.java
Outdated
Show resolved
Hide resolved
...cksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBConfigurableOptions.java
Outdated
Show resolved
Hide resolved
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks for the update!
I think this PR looks good in general except a test case.
...est/java/org/apache/flink/contrib/streaming/state/RocksDBIncrementalCheckpointUtilsTest.java
Outdated
Show resolved
Hide resolved
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks for the update! LGTM.
@flinkbot run azure |
…on of incremental restoring configurable
…cremental restoring configurable This closes apache#19106.
…cremental restoring configurable This closes apache#19106.
…cremental restoring configurable This closes apache#19106.
What is the purpose of the change
Currently, the threshold of the overlap fraction of incremental restoring
OVERLAP_FRACTION_THRESHOLD
is a hard-coded, fixed value.OVERLAP_FRACTION_THRESHOLD
is used to control how to restore a state handle, different thresholds can affect the performance of restoring. The behavior of deletion in restoring has been changed after FLINK-21321, the old threshold no longer fits the current situation.To make it easier to modify the threshold according to different situations, changing
OVERLAP_FRACTION_THRESHOLD
to be configurable is suggested.Brief change log
RESTORE_OVERLAP_FRACTION_THRESHOLD
into RocksDBConfigurableOptions.Verifying this change
This change added tests and can be verified as follows:
Does this pull request potentially affect one of the following parts:
@Public(Evolving)
: (yes / no)Documentation