Description:
In group_replication cluster, if group_name is A, the next gtid_no is xx, and set gtid_next='A:xx' in one session, but other session can still take over the gtid_no.
If consistcy is BEFORE, after gtid_no=xx written, new query will blocked
How to repeat:
1. first use mtr to start 2 servers
./mysql-test/mtr gr_abort_query_on_plugin_error --start
2. connect 13000, and start mgr
mysql> set GLOBAL group_replication_bootstrap_group=ON;
Query OK, 0 rows affected (0.00 sec)
mysql> set persist group_replication_group_name='aabbccdd-aabb-aabb-aabb-aabbccddeeff',persist group_replication_group_seeds='127.0.0.1:33061,127.0.0.1:33062',persist group_replication_local_address='127.0.0.1:33061';set global group_replication_consistency='eventual';CHANGE MASTER TO MASTER_USER="root" FOR CHANNEL "group_replication_recovery";start group_replication;
Query OK, 0 rows affected (0.00 sec)
Query OK, 0 rows affected (0.00 sec)
Query OK, 0 rows affected, 3 warnings (0.02 sec)
Query OK, 0 rows affected (2.24 sec)
mysql> set GLOBAL group_replication_bootstrap_group=OFF;
Query OK, 0 rows affected (0.00 sec)
3. connect 13002, and start mgr
mysql> set persist group_replication_group_name='aabbccdd-aabb-aabb-aabb-aabbccddeeff',persist group_replication_group_seeds='127.0.0.1:33061,127.0.0.1:33062',persist group_replication_local_address='127.0.0.1:33062';set global group_replication_consistency='eventual';CHANGE MASTER TO MASTER_USER="root" FOR CHANNEL "group_replication_recovery";start group_replication;
Query OK, 0 rows affected (0.01 sec)
Query OK, 0 rows affected (0.00 sec)
Query OK, 0 rows affected, 3 warnings (0.03 sec)
Query OK, 0 rows affected (2.44 sec)
mysql> select * from performance_schema.replication_group_members; +---------------------------+--------------------------------------+-------------+-------------+--------------+-------------+----------------+
| CHANNEL_NAME | MEMBER_ID | MEMBER_HOST | MEMBER_PORT | MEMBER_STATE | MEMBER_ROLE | MEMBER_VERSION |
+---------------------------+--------------------------------------+-------------+-------------+--------------+-------------+----------------+
| group_replication_applier | 259fd4ab-d483-11eb-a7a6-c8f7507e5048 | 127.0.0.1 | 13000 | ONLINE | PRIMARY | 8.0.25 |
| group_replication_applier | 25a182f4-d483-11eb-a7be-c8f7507e5048 | 127.0.0.1 | 13002 | ONLINE | PRIMARY | 8.0.25 |
+---------------------------+--------------------------------------+-------------+-------------+--------------+-------------+----------------+
2 rows in set (0.03 sec)
4. connect 13000, init and set gtid_next
mysql> create table t1 (c1 int primary key, c2 int) engine=innodb; Query OK, 0 rows affected (0.05 sec)
mysql> insert into t1 values (1,1); Query OK, 1 row affected (0.02 sec)
mysql> show master status; +--------------------------+----------+--------------+------------------+------------------------------------------+
| File | Position | Binlog_Do_DB | Binlog_Ignore_DB | Executed_Gtid_Set |
+--------------------------+----------+--------------+------------------+------------------------------------------+
| server-binary-log.000001 | 1375 | | | aabbccdd-aabb-aabb-aabb-aabbccddeeff:1-4 |
+--------------------------+----------+--------------+------------------+------------------------------------------+
1 row in set (0.00 sec)
mysql> set session gtid_next='aabbccdd-aabb-aabb-aabb-aabbccddeeff:5';
Query OK, 0 rows affected (0.00 sec)
5. use another terminal, connect 13000, do insert
mysql> show master status; +--------------------------+----------+--------------+------------------+------------------------------------------+
| File | Position | Binlog_Do_DB | Binlog_Ignore_DB | Executed_Gtid_Set |
+--------------------------+----------+--------------+------------------+------------------------------------------+
| server-binary-log.000001 | 1375 | | | aabbccdd-aabb-aabb-aabb-aabbccddeeff:1-4 |
+--------------------------+----------+--------------+------------------+------------------------------------------+
1 row in set (0.00 sec)
mysql> insert into t1 values (2,2);
Query OK, 1 row affected (0.02 sec)
mysql> show master status;
+--------------------------+----------+--------------+------------------+------------------------------------------+
| File | Position | Binlog_Do_DB | Binlog_Ignore_DB | Executed_Gtid_Set |
+--------------------------+----------+--------------+------------------+------------------------------------------+
| server-binary-log.000001 | 1665 | | | aabbccdd-aabb-aabb-aabb-aabbccddeeff:1-5 |
+--------------------------+----------+--------------+------------------+------------------------------------------+
1 row in set (0.00 sec)
6. and then do query, it will not return
mysql> set session group_replication_consistency='BEFORE';
Query OK, 0 rows affected (0.00 sec)
mysql> select * from t1;
7. open other connect to 13000
mysql> show processlist;
+----+-----------------+-----------------+------+---------+------+--------------------------------------------------------+----------------------------------+---------+-----------+---------------+
| Id | User | Host | db | Command | Time | State | Info | Time_ms | Rows_sent | Rows_examined |
+----+-----------------+-----------------+------+---------+------+--------------------------------------------------------+----------------------------------+---------+-----------+---------------+
| 5 | event_scheduler | localhost | NULL | Daemon | 706 | Waiting on empty queue | NULL | 706067 | 0 | 0 |
| 21 | system user | | NULL | Connect | 573 | waiting for handler commit | Group replication applier module | 572692 | 0 | 0 |
| 24 | system user | | NULL | Query | 573 | Slave has read all relay log; waiting for more updates | NULL | 547320 | 0 | 0 |
| 32 | root | localhost:44478 | test | Sleep | 512 | | NULL | 512441 | 0 | 0 |
| 33 | root | localhost:44488 | test | Query | 481 | Executing hook on transaction begin. | select * from t1 | 480745 | 0 | 0 |
| 34 | root | localhost:44502 | test | Query | 0 | init | show processlist | 0 | 0 | 0 |
+----+-----------------+-----------------+------+---------+------+--------------------------------------------------------+----------------------------------+---------+-----------+---------------+
6 rows in set (0.01 sec)
