-
Notifications
You must be signed in to change notification settings - Fork 2.1k
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
VReplication: Address SwitchWrites bugs around replication lag and cancel on error #17616
base: main
Are you sure you want to change the base?
Conversation
Signed-off-by: Matt Lord <[email protected]>
Signed-off-by: Matt Lord <[email protected]>
Review ChecklistHello reviewers! 👋 Please follow this checklist when reviewing this Pull Request. General
Tests
Documentation
New flags
If a workflow is added or modified:
Backward compatibility
|
59340f2
to
4800b81
Compare
Signed-off-by: Matt Lord <[email protected]>
4800b81
to
4e8e109
Compare
Codecov ReportAttention: Patch coverage is
Additional details and impacted files@@ Coverage Diff @@
## main #17616 +/- ##
==========================================
- Coverage 67.69% 67.66% -0.03%
==========================================
Files 1586 1586
Lines 255403 255407 +4
==========================================
- Hits 172883 172826 -57
- Misses 82520 82581 +61 ☔ View full report in Codecov by Sentry. |
Signed-off-by: Matt Lord <[email protected]>
Signed-off-by: Matt Lord <[email protected]>
Signed-off-by: Matt Lord <[email protected]>
Signed-off-by: Matt Lord <[email protected]>
updatedTs = &vttimepb.Time{} | ||
} | ||
lastUpdateTime := updatedTs.Seconds | ||
if state == binlogdatapb.VReplicationWorkflowState_Copying { |
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.
Maybe worth returning maxint
for any state other than Running
// Confirm that switching writes works as expected in the face of | ||
// vreplication lag (canSwitch() precheck) and when cancelling the | ||
// switch due to replication failing to catch up in time. | ||
t.Run("validate switch writes error handling", func(t *testing.T) { |
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.
let's extract this into a separate method.
Description
Related Issue(s)
Checklist