-
Notifications
You must be signed in to change notification settings - Fork 1.2k
fix: fix replication on pika node recovering #3038
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
fix: fix replication on pika node recovering #3038
Conversation
wangshao1
commented
Mar 7, 2025
- 修复pika slave节点恢复之后,dashboard没有更新元信息的问题。
- 修复info replication master ip:port 解析失败的问题。
Important Review skippedAuto reviews are disabled on base/target branches other than the default branch. Please check the settings in the CodeRabbit UI or the You can disable this status message by setting the Thanks for using CodeRabbit! It's free for OSS, and your support helps us grow. If you like it, consider giving us a shout-out. 🪧 TipsChatThere are 3 ways to chat with CodeRabbit:
Note: Be mindful of the bot's finite context window. It's strongly recommended to break down tasks such as reading entire modules into smaller chunks. For a focused discussion, use review comments to chat about specific files and their changes, instead of using the PR comments. CodeRabbit Commands (Invoked using PR comments)
Other keywords and placeholders
CodeRabbit Configuration File (
|
|
||
err = s.tryFixReplicationRelationship(group, state.Server, state, masterOffGroupLen) | ||
err = s.tryFixReplicationRelationship(group, state.Server, state) | ||
if err != nil { |
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.
这一个 tryFixReplicationRelationship 处于一个 for 循环中,下面第 356 行有通知 Proxy 变更元信息的步骤,这里是不是应该等所有的 state 都处理完之后再去变更元信息
// current server is slave, execute the command `slaveof [new master ip] [new master port]` | ||
if err = updateMasterToNewOne(groupServer.Addr, curMasterAddr, s.config.ProductAuth); err != nil { | ||
return err | ||
} |
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.
这里的第400行 err = s.storeUpdateGroup(group) 看着这个元信息变更是多余的,可以考虑删掉
* fix invalid arguments error when dashboard send slveof force Co-authored-by: wangshaoyi <wangshaoyi@360.cn>
a8fbe5b
to
ea7e1b5
Compare
* fix: Reduced ReadCache tags for some commands (#3034) * fix: Fixed an issue with asynchronous loading (#3037) * summary different stages duration && add rocksdb perfcontext (#3036) * fix: The number of element updates in RedisCache is configurable (#3043) * The number of element updates in RedisCache is configurable Co-authored-by: wuxianrong <wuxianrong@360.cn> * fix: fix replication on pika node recovering (#3038) * fix: Fix problems found during testing (#3039) * Example Modify the policy for updating big keys except String to Redis-Cache (#3047) Co-authored-by: wuxianrong <wuxianrong@360.cn> * add auth command to admin-thread-pool (#3048) Co-authored-by: wuxianrong <wuxianrong@360.cn> * fix: Example Repair the subjective and objective offline logic of noeds (#3049) * Example Repair the subjective and objective offline logic of primary and secondary nodes * fix comment --------- Co-authored-by: wuxianrong <wuxianrong@360.cn> * fix: Fixed version information for Pika, Pika_exporter, Codis (#3054) * Fixed version information for Pika, Pika_exporter, Codis * Delete redundant logic --------- Co-authored-by: wuxianrong <wuxianrong@360.cn> * fix: Fixed versions of Pika, Pika_exporter, Codis (#3057) * Resolve conflict differences * Resolve conflict differences * Resolve conflict differences * fix string test * change by review --------- Co-authored-by: wangshao1 <30471730+wangshao1@users.noreply.github.com> Co-authored-by: wuxianrong <wuxianrong@360.cn>
* fix: Reduced ReadCache tags for some commands (OpenAtomFoundation#3034) * fix: Fixed an issue with asynchronous loading (OpenAtomFoundation#3037) * summary different stages duration && add rocksdb perfcontext (OpenAtomFoundation#3036) * fix: The number of element updates in RedisCache is configurable (OpenAtomFoundation#3043) * The number of element updates in RedisCache is configurable Co-authored-by: wuxianrong <wuxianrong@360.cn> * fix: fix replication on pika node recovering (OpenAtomFoundation#3038) * fix: Fix problems found during testing (OpenAtomFoundation#3039) * Example Modify the policy for updating big keys except String to Redis-Cache (OpenAtomFoundation#3047) Co-authored-by: wuxianrong <wuxianrong@360.cn> * add auth command to admin-thread-pool (OpenAtomFoundation#3048) Co-authored-by: wuxianrong <wuxianrong@360.cn> * fix: Example Repair the subjective and objective offline logic of noeds (OpenAtomFoundation#3049) * Example Repair the subjective and objective offline logic of primary and secondary nodes * fix comment --------- Co-authored-by: wuxianrong <wuxianrong@360.cn> * fix: Fixed version information for Pika, Pika_exporter, Codis (OpenAtomFoundation#3054) * Fixed version information for Pika, Pika_exporter, Codis * Delete redundant logic --------- Co-authored-by: wuxianrong <wuxianrong@360.cn> * fix: Fixed versions of Pika, Pika_exporter, Codis (OpenAtomFoundation#3057) * Resolve conflict differences * Resolve conflict differences * Resolve conflict differences * fix string test * change by review --------- Co-authored-by: wangshao1 <30471730+wangshao1@users.noreply.github.com> Co-authored-by: wuxianrong <wuxianrong@360.cn>
* fix: tryFixReplicationRelationships error (OpenAtomFoundation#2991) * fix invalid arguments error when dashboard send slveof force Co-authored-by: wangshaoyi <wangshaoyi@360.cn> * fix replication relationship error while recovering from offline * update proxy slot mappings after slave pika recovered --------- Co-authored-by: wangshaoyi <wangshaoyi@360.cn>