mysql主从复制出现Waiting for Slave Worker to release partition

本文涉及的产品
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
RDS MySQL Serverless 高可用系列,价值2615元额度,1个月
简介: 本文分享mysql主从复制出现Waiting for Slave Worker to release partition

作者:手辨



实为吾之愚见,望诸君酌之!闻过则喜,与君共勉 


第一节并行复制


Mysql5.6的mts(并行复制)是基于database来分发事务的,coordinator(原来的sql
thread)按照slave worker与db的对应关系进行处理来分发事务给相应的slave worker,slave worker代替了sql thread来执行事务中的event。并且mysql默认认为数据是以database来分布的,跨库的事务在slave应用的时候可能就需要等待了。


Waiting for Slave Worker to release
partition第一次看到是在开启MTS的mysql5.6主从复制的时候,在Slave_SQL_Running_State:出现Waiting for Slave
Worker to release partition,Slave_SQL_Running_State的状态比较多,但是这个状态翻译过来是指“等待slave worker 释放
分区(partitions)”,其中的partitions解释成中文不是很正确,partitions可以理解成”按照slave worker与db的对应关系进行分发事务后的对象”(有更好的解释请留言),它既不是事务也不是event,也不是单纯的对应关系,起码可以确定这种情况并不是异常的情况(大部分时候),slave worker正在应用coordinator分配的内容但是还没结束,coordinator需要等待之前分配的内容应用完成才可以继续分配(coordinator还没有将其放入slave worker的queue),下面尝试测试和复现Waiting for Slave Worker to release partition。


当不开启并行复制时(slave_parallel_workers 0),show processlist是这样的:


1be0fce0fcc0befdee9f612c378e65d0cad4b2f0


当开启并行复制时(slave_parallel_workers为2),show
processlist是这样的:


44a30bdd7fbeee1f7ca379e2701212fb871d6c15


区别是增加了两个slave worker进程,原来的sql thread变成了
coordinator。


 


第二节测试和复现


2.1 创建测试数据


1,创建两个测试的database:slavetest,slavetest1


2,在这两个db中分布创建一张表test,向里面写入200w左右的测试数据


通过测试一些场景,通过其结果来反应一些问题,以下测试多是基于自建mysql进行


2.2 测试1


确认slave worker与db的在串行执行时对应关系,先打开一个session,分别执行


update slavetest.test set
trade='slavetest';


update slavetest1.test set
trade='slavetest1';


查看slave的slave worker状态,找到slavetest对应的slave worker


250de12139193c2cf3243f2f14f6c32307eec356


415ab02b4d15f19f3296cc6470f47580a731d2b7


8260139c77fa04b780d2f500f6c829890c5e8e5c


通过上面测试slavetest对应的slave worker的进程id为5812476


使用同样的方法,得出如下对应:


slavetest     5812476


slavetest1        5812475


这样单线程执行的时候,两个db在执行update更新时,coordinator都分配给了5812476的slave worker


2.3 测试2


确认slave worker与db的在并行执行时对应关系,同事打开2个session,每个session分别执行更新,中间间隔10s

update slavetest.test set trade='slavetest11';


update slavetest1.test set
trade='slavetest22';


查看slave的slave worker状态,找到slavetest对应的slave worker(可以写一个脚本来循环执行show processlist监控)


0a19d5e44179efaa835733b0df98e36f8d6b54e8


5839a4b953a45aa7fd4a651c763de0ea54ace2bf


通过执行信息看,slavetest1的事务先完成,slavetest2的事务后完成,看下slave的进程信息:


93ad62e18f6540301315e128a4b5c61f62294327


f3fc005eff2f41a4817f04c14d166b3c7884e415


2988e97dc4812ef2c99d0498c86f335fdfbe3a4e


过滤后如下:


9df51f7679c7d9d3e611892cd3450481a27085a0


9e1c77581902c887880830562214be2618f3775e


aba24418a769a8384164b83fe794dcf7b565ea61


789806dae9267460f0c9cd8536b187cec9b3e6b8


86f1a98f44a3a0e13bcf93a53f4cca77b4e8090d


通过上面测试并不能在slave上执行完这两个事务的时候,保证一个slave worker完全对应其中的一个dbname(个人以为上一个事务里面,slave worker与db的对应是不会变的),暂且得出的结论是当并行执行两个db的事务的时候,其中的两个slave worker都产生了影响。


这样多线程执行的时候,两个db在执行update更新时,coordinator会把事务分配给两个slave worker同时并行执行,并且也出现了Waiting for Slave Worker to release partition,并且还出现了Waiting
for Slave Worker queue,按照之前的描述,mysql假设数据是按照database来分布的,所以不会存在跨库的情况,下面进行事务跨库的测试


2.4 测试3


确认slave worker与db的在一个事务里跨库执行时对应关系,只打开1个session,执行:

begin;


update slavetest.test set
trade='slavetest1';


update slavetest1.test set
trade='slavetest2';


commit;


查看slave的slave worker状态,找到slavetest对应的slave worker(可以写一个脚本来循环执行show processlist监控)


6aecc4ff937f4ba61c0b97bac6901ab203075b5d


模拟一个事务内跨库执行更新,查看slave的进程信息:


d4f7e9c82554b2199f6b87a10ca8b0bd551d5f8d


b8e31e5ce9d7a9eae23e2941fb9eafadb83afc23




通过过滤的结果看,执行event的进程只有一个5812476,coordinator并没有分配给5812475的slave worker来执行,且也出现了Waiting for Slave Worker to release partition


 


通过测试和复现问题,Waiting for Slave Worker to release partition一般来说是一个正常的中间状态,但是也有可能出现问题,有一些特殊情况可以参考:


https://bugs.mysql.com/bug.php?id=73066


https://bugs.mysql.com/bug.php?id=72794


另外包括Waiting for Slave Worker queue,System lock等状态大部分也是正常的中间状态


相关实践学习
如何在云端创建MySQL数据库
开始实验后,系统会自动创建一台自建MySQL的 源数据库 ECS 实例和一台 目标数据库 RDS。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助     相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
相关文章
|
28天前
|
SQL 关系型数据库 MySQL
mysql主从复制概述和配置
【10月更文挑战第22天】MySQL 主从复制是一种将主服务器的数据复制到一个或多个从服务器的技术,实现读写分离,提高系统性能和可用性。主服务器记录变更日志,从服务器通过 I/O 和 SQL 线程读取并应用这些变更。适用于读写分离、数据备份和恢复、数据分析等场景。配置步骤包括修改配置文件、创建复制用户、配置从服务器连接主服务器并启动复制进程。
|
1月前
|
监控 关系型数据库 MySQL
深入了解MySQL主从复制:构建高效稳定的数据同步架构
深入了解MySQL主从复制:构建高效稳定的数据同步架构
120 1
|
22天前
|
存储 关系型数据库 MySQL
MySQL主从复制原理和使用
本文介绍了MySQL主从复制的基本概念、原理及其实现方法,详细讲解了一主两从的架构设计,以及三种常见的复制模式(全同步、异步、半同步)的特点与适用场景。此外,文章还提供了Spring Boot环境下配置主从复制的具体代码示例,包括数据源配置、上下文切换、路由实现及切面编程等内容,帮助读者理解如何在实际项目中实现数据库的读写分离。
MySQL主从复制原理和使用
|
22天前
|
SQL 关系型数据库 MySQL
Mysql中搭建主从复制原理和配置
主从复制在数据库管理中广泛应用,主要优点包括提高性能、实现高可用性、数据备份及灾难恢复。通过读写分离、从服务器接管、实时备份和地理分布等机制,有效增强系统的稳定性和数据安全性。主从复制涉及I/O线程和SQL线程,前者负责日志传输,后者负责日志应用,确保数据同步。配置过程中需开启二进制日志、设置唯一服务器ID,并创建复制用户,通过CHANGE MASTER TO命令配置从服务器连接主服务器,实现数据同步。实验部分展示了如何在两台CentOS 7服务器上配置MySQL 5.7主从复制,包括关闭防火墙、配置静态IP、设置域名解析、配置主从服务器、启动复制及验证同步效果。
Mysql中搭建主从复制原理和配置
|
2月前
|
存储 关系型数据库 MySQL
分析MySQL主从复制中AUTO_INCREMENT值不一致的问题
通过对 `AUTO_INCREMENT`不一致问题的深入分析和合理应对措施的实施,可以有效地维护MySQL主从复制环境中数据的一致性和完整性,确保数据库系统的稳定性和可靠性。
99 6
|
2月前
|
存储 关系型数据库 MySQL
分析MySQL主从复制中AUTO_INCREMENT值不一致的问题
通过对 `AUTO_INCREMENT`不一致问题的深入分析和合理应对措施的实施,可以有效地维护MySQL主从复制环境中数据的一致性和完整性,确保数据库系统的稳定性和可靠性。
65 1
|
2月前
|
关系型数据库 MySQL Java
MySQL主从复制实现读写分离
MySQL主从复制(二进制日志)、 Sharding-JDBC实现读写分离
MySQL主从复制实现读写分离
|
8天前
|
SQL 关系型数据库 MySQL
go语言数据库中mysql驱动安装
【11月更文挑战第2天】
23 4
|
6天前
|
SQL 关系型数据库 MySQL
12 PHP配置数据库MySQL
路老师分享了PHP操作MySQL数据库的方法,包括安装并连接MySQL服务器、选择数据库、执行SQL语句(如插入、更新、删除和查询),以及将结果集返回到数组。通过具体示例代码,详细介绍了每一步的操作流程,帮助读者快速入门PHP与MySQL的交互。
20 1
|
15天前
|
监控 关系型数据库 MySQL
数据库优化:MySQL索引策略与查询性能调优实战
【10月更文挑战第27天】本文深入探讨了MySQL的索引策略和查询性能调优技巧。通过介绍B-Tree索引、哈希索引和全文索引等不同类型,以及如何创建和维护索引,结合实战案例分析查询执行计划,帮助读者掌握提升查询性能的方法。定期优化索引和调整查询语句是提高数据库性能的关键。
81 1