-
Notifications
You must be signed in to change notification settings - Fork 288
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
Optimsitic: refine optimstic create/drop table #4497
Optimsitic: refine optimstic create/drop table #4497
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.
https://github.com/GMHDBJD/ticdc/blob/refineOptimsticCreateTable/dm/dm/master/shardddl/optimist_test.go#L488
Should we remove this function and use the new method in UTs?
Will review later
/run-all-tests |
cc @lichunzhu |
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
/run-all-tests |
/run-all-tests |
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.
will review later
for routeTable := range droppedTable { | ||
lock := o.lk.FindLock(utils.GenDDLLockID(st.Task, routeTable.DownSchema, routeTable.DownTable)) | ||
if lock != nil { | ||
cols := lock.TryRemoveTable(st.Source, routeTable.UpSchema, routeTable.UpTable) |
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.
if after remove tables the joined table has changed and a DDL should be executed to downstream, how do we handle it?
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.
We cannot handle it. e.g. 2 tables
table1 drop column a
drop table2
Now actually we should drop column a in Downstream, but we can't now.
/run-all-tests |
/run-verify |
/merge |
This pull request has been accepted and is ready to merge. Commit hash: efa693d
|
/run-dm-integration-test |
/run-dm-integration-test |
What problem does this PR solve?
Issue Number: close #3823
What is changed and how it works?
Check List
Tests
Code changes
Side effects
Related changes
Release note