-
Notifications
You must be signed in to change notification settings - Fork 188
dmctl, scheduler: support manually transfer-source #1492
Conversation
Maybe |
OK, I haven't add dmctl part |
so I prefer |
failpoint.Inject("failToReplaceSourceBound", func(_ failpoint.Value) { | ||
failpoint.Return(errors.New("failToPutSourceBound")) | ||
}) | ||
_, err := ha.ReplaceSourceBound(s.etcdCli, source, oldWorker.BaseInfo().Name, worker) |
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.
Is there any problem when the last worker doesn't stop its own source timely?
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.
Delete source bound can't handle it? If so, we may have the same problem when there is a network isolation between worker and master.
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.
/lgtm |
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.
/lgtm
going to stop transfer when there's running subtask on it, to avoid new and old worker both online |
/run-all-tests |
/lgtm |
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.
LGTM
Signed-off-by: ti-srebot <ti-srebot@pingcap.com>
cherry pick to release-2.0 in PR #1509 |
What problem does this PR solve?
close #1075
What is changed and how it works?
support transfer a source to a free worker by
transfer-source -s <sourc-id> -w <worker-id>
Check List
Tests
Code changes
Side effects
Related changes