Skip to content

enable active-active check#4066

Closed
Leavrth wants to merge 1 commit intopingcap:feature/active-activefrom
Leavrth:enable_active_active_check
Closed

enable active-active check#4066
Leavrth wants to merge 1 commit intopingcap:feature/active-activefrom
Leavrth:enable_active_active_check

Conversation

@Leavrth
Copy link

@Leavrth Leavrth commented Jan 26, 2026

What problem does this PR solve?

Issue Number: close #xxx

What is changed and how it works?

Check List

Tests

  • Unit test
  • Integration test
  • Manual test (add detailed scripts or steps below)
  • No code

Questions

Will it cause performance regression or break compatibility?
Do you need to update user documentation, design documentation or monitoring documentation?

Release note

Please refer to [Release Notes Language Style Guide](https://pingcap.github.io/tidb-dev-guide/contribute-to-tidb/release-notes-style-guide.html) to write a quality release note.

If you don't think this PR needs a release note then fill it with `None`.

Signed-off-by: Jianjun Liao <jianjun.liao@outlook.com>
@ti-chi-bot ti-chi-bot bot added first-time-contributor Indicates that the PR was contributed by an external member and is a first-time contributor. release-note Denotes a PR that will be considered when it comes time to generate release notes. labels Jan 26, 2026
@ti-chi-bot
Copy link

ti-chi-bot bot commented Jan 26, 2026

[APPROVALNOTIFIER] This PR is NOT APPROVED

This pull-request has been approved by:
Once this PR has been reviewed and has the lgtm label, please assign flowbehappy for approval. For more information see the Code Review Process.
Please ensure that each of them provides their approval before proceeding.

The full list of commands accepted by this bot can be found here.

Details Needs approval from an approver in each of these files:

Approvers can indicate their approval by writing /approve in a comment
Approvers can cancel approval by writing /approve cancel in a comment

@pingcap-cla-assistant
Copy link

CLA assistant check
Thank you for your submission! We really appreciate it. Like many open source projects, we ask that you sign our Contributor License Agreement before we can accept your contribution.
You have signed the CLA already but the status is still pending? Let us recheck it.

@ti-chi-bot ti-chi-bot bot added the size/L Denotes a PR that changes 100-499 lines, ignoring generated files. label Jan 26, 2026
@gemini-code-assist
Copy link

Summary of Changes

Hello @Leavrth, 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 introduces a new configuration flag to fine-tune the behavior of active-active replication by allowing a bypass of certain conflict detection checks. This provides operators with more granular control over how DML events are processed in an active-active setup, potentially optimizing performance or handling specific replication scenarios.

Highlights

  • New Configuration Option: Introduced a new boolean configuration field, EnableActiveActiveCheck, across the API, internal configuration, and replica configuration structures. This new field provides a toggle for specific active-active replication checks.
  • Conditional Active-Active Check Bypass: Modified the EvaluateRowPolicy function in pkg/common/event/active_active.go to conditionally bypass active-active row policy evaluation. When EnableActiveActiveCheck is true, the function will immediately return RowPolicyKeep, effectively disabling certain conflict filtering for the row.
  • Propagation of New Field: The EnableActiveActiveCheck field has been propagated through the downstreamadapter/dispatcher components, including SharedInfo struct, constructor functions, and calls to FilterDMLEvent, ensuring the new configuration is accessible and utilized where needed.
  • Test Updates: Updated various test files within the downstreamadapter/dispatcher and pkg/common/event directories to accommodate the new enableActiveActiveCheck parameter in function calls and test setups.

🧠 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 Assist

The 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 /gemini <command> or @gemini-code-assist <command>. Below is a summary of the supported commands on the current page.

Feature Command Description
Code Review /gemini review Performs a code review for the current pull request in its current state.
Pull Request Summary /gemini summary Provides a summary of the current pull request in its current state.
Comment @gemini-code-assist Responds in comments when explicitly tagged, both in pull request comments and review comments.
Help /gemini help Displays a list of available commands.

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 .gemini/ folder in the base of the repository. Detailed instructions can be found here.

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

  1. Review the Privacy Notices, Generative AI Prohibited Use Policy, Terms of Service, and learn how to configure Gemini Code Assist in GitHub here. Gemini can make mistakes, so double check it and use code with caution.

Copy link

@gemini-code-assist gemini-code-assist bot left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Code Review

This pull request introduces a new configuration option, enable_active_active_check, to control event filtering in active-active replication scenarios. The changes are propagated through the configuration and dispatcher layers to the core event filtering logic.

My review focuses on two main points:

  1. Missing Validation: The new configuration lacks validation, which could lead to misconfiguration and potential issues. I've pointed out where similar validation for enable_active_active exists and suggested adding checks for the new flag.
  2. Code Clarity: The implementation of the new logic in the event filtering function could be clearer. I've suggested a refactoring to improve readability and maintainability.

Overall, the changes are in the right direction, but addressing the validation point is crucial before merging.

SyncedStatus *SyncedStatusConfig `toml:"synced-status" json:"synced-status,omitempty"`

EnableActiveActive *bool `toml:"enable-active-active" json:"enable-active-active,omitempty"`
EnableActiveActiveCheck *bool `toml:"enable-active-active-check" json:"enable-active-active-check,omitempty"`

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

high

The new configuration EnableActiveActiveCheck seems to be missing validation in ValidateAndAdjust. Given its name and its effect in EvaluateRowPolicy, it appears to be related to active-active replication.

The existing EnableActiveActive flag has several important validations, such as ensuring BDRMode is enabled, checking for a compatible sink (MySQL/TiDB), and ensuring it's not used with redo log consistency.

To prevent potential data inconsistency or runtime errors from misconfiguration, similar validations should be added for EnableActiveActiveCheck. For example:

  • Should BDRMode be required?
  • Is it only compatible with MySQL/TiDB sinks?
  • Is it incompatible with redo log?

Please add the necessary validation logic for EnableActiveActiveCheck in the ValidateAndAdjust function.

Comment on lines +79 to +81
if enableActiveActiveCheck {
return RowPolicyKeep, nil
}

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

medium

The logic here is a bit confusing. This check for enableActiveActiveCheck is only executed if enableActiveActive is false due to the preceding if statement. If the intention is for either flag to have the same effect of keeping the row, it would be clearer to combine them into a single condition: if enableActiveActive || enableActiveActiveCheck. While this would require changing code outside this diff, it's worth considering for better maintainability.

@Leavrth Leavrth closed this Feb 2, 2026
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

first-time-contributor Indicates that the PR was contributed by an external member and is a first-time contributor. release-note Denotes a PR that will be considered when it comes time to generate release notes. size/L Denotes a PR that changes 100-499 lines, ignoring generated files.

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant

Comments