-
Notifications
You must be signed in to change notification settings - Fork 283
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
Owner: Fix gcttl bug #1861
Owner: Fix gcttl bug #1861
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.
rest /lgtm
cdc/owner.go
Outdated
if changefeed.status.CheckpointTs < minGCSafePoint { | ||
// 2. We need the <= check here is because when a changefeed is stagnant, its checkpointTs will be updated to pd, | ||
// and it would be the minimum gcSafePoint of cdc. In order to avoid circular dependence, it is necessary to check for equality. | ||
// Checking whether they are equal will make the loop assignment to happen only once, and then it will be skipped in next time. |
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.
What is loop assignment
? Can you be more specific?
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.
done
/lgtm |
[REVIEW NOTIFICATION] This pull request has been approved by:
To complete the pull request process, please ask the reviewers in the list to review by filling The full list of commands accepted by this bot can be found here. Reviewer can indicate their review by writing |
/merge |
This pull request has been accepted and is ready to merge. Commit hash: a265de3
|
/rebuild |
/run-all-tests |
/run-unit-tests |
/run-all-tests |
1 similar comment
/run-all-tests |
/rerun-integration-tests |
/run-integration-tests |
/run-kafka-tests |
2 similar comments
/run-kafka-tests |
/run-kafka-tests |
In response to a cherrypick label: new pull request created: #1871. |
In response to a cherrypick label: new pull request created: #1872. |
What problem does this PR solve?
#1839
What is changed and how it works?
Modify the calculation method of MinGCSafePoint (the lower bound of CDC's gcSafePoint)
Before:
MinGCSafePoint = curentTs - gcTTL
After:
MinGCSafePoint = min(curentTs - gcTTL, pdSafePoint)
Check List
Tests
Side effects
Related changes
Release note