fix(ddl): wait running add index before CREATE TABLE LIKE#3863
Conversation
Summary of ChangesHello @wlwilliamx, I'm Gemini Code Assist1! I'm currently reviewing this pull request and will post my feedback shortly. In the meantime, here's a summary to help you and other reviewers quickly get up to speed! This pull request addresses a critical schema consistency problem in TiCDC where a Highlights
🧠 New Feature in Public Preview: You can now enable Memory to help Gemini Code Assist learn from your team's feedback. This makes future code reviews more consistent and personalized to your project's style. Click here to enable Memory in your admin console. Using Gemini Code AssistThe full guide for Gemini Code Assist can be found on our documentation page, here are some quick tips. Invoking Gemini You can request assistance from Gemini at any point by creating a comment using either
Customization To customize Gemini Code Assist for GitHub experience, repository maintainers can create a configuration file and/or provide a custom code review style guide (such as PEP-8 for Python) by creating and adding files to a Limitations & Feedback Gemini Code Assist may make mistakes. Please leave feedback on any instances where its feedback is incorrect or counter productive. You can react with 👍 and 👎 on @gemini-code-assist comments. If you're interested in giving your feedback about your experience with Gemini Code Assist for Github and other Google products, sign up here. You can also get AI-powered code generation, chat, as well as code reviews directly in the IDE at no cost with the Gemini Code Assist IDE Extension. Footnotes
|
There was a problem hiding this comment.
Code Review
This pull request effectively addresses the schema inconsistency issue with CREATE TABLE ... LIKE ... by ensuring it waits for any ongoing ADD INDEX operations on the referenced table. The approach of identifying the referenced table in the schemastore and adjusting the sink's waiting logic is sound. The changes are well-supported by both unit and integration tests, which provides good confidence in the fix. I have one minor suggestion to improve code readability.
|
/retest |
|
/test all |
|
/test all |
|
/test pull-cdc-mysql-integration-light |
|
/test pull-cdc-mysql-integration-heavy |
|
/test all |
|
/retest |
|
/test all |
|
/retest |
3 similar comments
|
/retest |
|
/retest |
|
/retest |
|
|
||
| func needWaitAsyncExecDone(t timodel.ActionType) bool { | ||
| switch t { | ||
| case timodel.ActionCreateTable, timodel.ActionCreateTables: |
There was a problem hiding this comment.
I think it is not a good idea to remove this. If there are lots of create table DDL, every table will query the downstream. It may affect performance. Could we handle the create table like separately?
There was a problem hiding this comment.
Removing create table and create tables here is irrelevant, because only create table like will have blocked table names. Only when there are blocked table names will the query add index and wait.
There was a problem hiding this comment.
Why we could remove this function?
|
/test pull-cdc-mysql-integration-light |
|
/test pull-cdc-mysql-integration-heavy |
|
[APPROVALNOTIFIER] This PR is APPROVED This pull-request has been approved by: lidezhu, wk989898 The full list of commands accepted by this bot can be found here. The pull request process is described here DetailsNeeds approval from an approver in each of these files:
Approvers can indicate their approval by writing |
|
/override pull-cdc-kafka-integration-heavy |
|
@wlwilliamx: Overrode contexts on behalf of wlwilliamx: pull-cdc-kafka-integration-heavy DetailsIn response to this:
Instructions for interacting with me using PR comments are available here. If you have questions or suggestions related to my behavior, please file an issue against the kubernetes-sigs/prow repository. |
* fix(ddl): fix create table like ddl don't wait add index * refactor ut * modify error handle * refactor * set BlockedTables for create table like ddl * make check * fix extract refer table info * fix test query * remove the useless func needWaitAsyncExecDone * modify search name with case sensitive
* fix(ddl): fix create table like ddl don't wait add index * refactor ut * modify error handle * refactor * set BlockedTables for create table like ddl * make check * fix extract refer table info * fix test query * remove the useless func needWaitAsyncExecDone * modify search name with case sensitive
* fix(ddl): fix create table like ddl don't wait add index * refactor ut * modify error handle * refactor * set BlockedTables for create table like ddl * make check * fix extract refer table info * fix test query * remove the useless func needWaitAsyncExecDone * modify search name with case sensitive (cherry picked from commit 5dfe293) Signed-off-by: tenfyzhong <tenfy@tenfy.cn>
* fix(ddl): fix create table like ddl don't wait add index * refactor ut * modify error handle * refactor * set BlockedTables for create table like ddl * make check * fix extract refer table info * fix test query * remove the useless func needWaitAsyncExecDone * modify search name with case sensitive
* fix(ddl): fix create table like ddl don't wait add index * refactor ut * modify error handle * refactor * set BlockedTables for create table like ddl * make check * fix extract refer table info * fix test query * remove the useless func needWaitAsyncExecDone * modify search name with case sensitive
What problem does this PR solve?
Issue Number: close #3832
What is changed and how it works?
Fix downstream schema inconsistency for CREATE TABLE ... LIKE ... when the referenced table has a long-running ADD INDEX that is still running/queueing in downstream TiDB. In this case, CREATE TABLE b LIKE a may copy the current downstream schema of a before the index becomes visible, causing b to miss the index.
This PR makes CREATE TABLE ... LIKE ... wait for any running async ADD INDEX on the referenced table before executing the CREATE TABLE ... LIKE ....
Check List
Tests
Questions
Will it cause performance regression or break compatibility?
None
Do you need to update user documentation, design documentation or monitoring documentation?
None
Release note