-
Notifications
You must be signed in to change notification settings - Fork 13.7k
[hotfix] Tracks the number of pending manual compactions. #27105
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
base: master
Are you sure you want to change the base?
[hotfix] Tracks the number of pending manual compactions. #27105
Conversation
|
@flinkbot run azure |
1 similar comment
|
@flinkbot run azure |
| } | ||
| } | ||
|
|
||
| public synchronized void addManualCompaction() { |
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.
the method name does not seem correct. haveManualCompactions refers to runningManualCompactions and pendingManualCompactions. I suggest scheduleManualCompaction.
| } | ||
| } | ||
|
|
||
| public synchronized void addManualCompaction() { |
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.
can we add some unit tests for this class.
I am curious about the method
private synchronized void cancel() {
pendingManualCompactions--;
}
If the cancel can be called while it is running then the pending counter could go negative - as we have already decremented the pending counter when we incremented the running one.
What is the purpose of the change
This pull request tracks the pendingManualCompactions in org.apache.flink.state.rocksdb.sstmerge.CompactionTracker:
Brief change log
pendingManualCompactions--in the code.pendingManualCompactions++to correct the logic.Verifying this change
This change is a trivial rework / code cleanup without any test coverage.
Does this pull request potentially affect one of the following parts:
@Public(Evolving): (no)Documentation