Skip to content

Commit 06d917a

Browse files
santoshbandainikep
santoshbanda
authored and
inikep
committed
FB8-80: Display row information in processlist for rbr threads (facebook#953) (facebook#953)
Summary: Jira ticket: https://jira.percona.com/browse/FB8-80 Reference Patch: facebook@564824a Set row_query using the fields unpacked from the row event. Use row_query in show processlist. Pull Request resolved: facebook#953 Reviewed By: lloyd Differential Revision: D14137212 Pulled By: lth
1 parent d411c6e commit 06d917a

13 files changed

+195
-99
lines changed

Diff for: ‎mysql-test/suite/rpl/r/rpl_invalid_mem_access_with_rows_query_log_event.result

+1-1
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ INSERT INTO t1 VALUES(1);
3131
SET DEBUG_SYNC= "now WAIT_FOR deleted_rows_query_ev";
3232
SELECT state,info FROM information_schema.processlist WHERE state like 'debug%';;
3333
state debug sync point: now
34-
info NULL
34+
info INSERT INTO test.t1 (1)
3535
Warnings:
3636
Level Warning
3737
Code 1287

Diff for: ‎mysql-test/suite/rpl/r/rpl_multi_source_row_stages.result

+18-18
Original file line numberDiff line numberDiff line change
@@ -44,36 +44,36 @@ Commit;
4444
check on channel_1
4545
include/start_slave_sql.inc [FOR CHANNEL 'channel_1']
4646
SET debug_sync= 'now WAIT_FOR signal.rpl_row_apply_progress_updated';
47-
include/assert.inc [PERFORMANCE_SCHEMA.threads reports: state=Applying batch of row changes (write), db=test, info LIKE "INSERT INTO t1 VALUES (1)", Query]
48-
include/assert.inc [INFORMATION_SCHEMA.processlist reports: db=test, info LIKE "INSERT INTO t1 VALUES (1)", command=Query]
49-
[SHOW PROCESSLIST reports: db=test, info LIKE "INSERT INTO t1 VALUES (1)", command=Query]
47+
include/assert.inc [PERFORMANCE_SCHEMA.threads reports: state=Applying batch of row changes (write), db=test, info LIKE "INSERT INTO test.t1 (1)", Query]
48+
include/assert.inc [INFORMATION_SCHEMA.processlist reports: db=test, info LIKE "INSERT INTO test.t1 (1)", command=Query]
49+
[SHOW PROCESSLIST reports: db=test, info LIKE "INSERT INTO test.t1 (1)", command=Query]
5050
SET debug_sync= 'now SIGNAL signal.rpl_row_apply_process_next_row';
5151
SET debug_sync= 'now WAIT_FOR signal.rpl_row_apply_progress_updated';
52-
include/assert.inc [PERFORMANCE_SCHEMA.threads reports: state=Applying batch of row changes (update), db=test, info LIKE "UPDATE t1 SET a= 2", Query]
53-
include/assert.inc [INFORMATION_SCHEMA.processlist reports: db=test, info LIKE "UPDATE t1 SET a= 2", command=Query]
54-
[SHOW PROCESSLIST reports: db=test, info LIKE "UPDATE t1 SET a= 2", command=Query]
52+
include/assert.inc [PERFORMANCE_SCHEMA.threads reports: state=Applying batch of row changes (update), db=test, info LIKE "UPDATE test.t1 (1)(2)", Query]
53+
include/assert.inc [INFORMATION_SCHEMA.processlist reports: db=test, info LIKE "UPDATE test.t1 (1)(2)", command=Query]
54+
[SHOW PROCESSLIST reports: db=test, info LIKE "UPDATE test.t1 (1)(2)", command=Query]
5555
SET debug_sync= 'now SIGNAL signal.rpl_row_apply_process_next_row';
5656
SET debug_sync= 'now WAIT_FOR signal.rpl_row_apply_progress_updated';
57-
include/assert.inc [PERFORMANCE_SCHEMA.threads reports: state=Applying batch of row changes (delete), db=test, info LIKE "DELETE FROM t1 WHERE a=2", Query]
58-
include/assert.inc [INFORMATION_SCHEMA.processlist reports: db=test, info LIKE "DELETE FROM t1 WHERE a=2", command=Query]
59-
[SHOW PROCESSLIST reports: db=test, info LIKE "DELETE FROM t1 WHERE a=2", command=Query]
57+
include/assert.inc [PERFORMANCE_SCHEMA.threads reports: state=Applying batch of row changes (delete), db=test, info LIKE "DELETE FROM test.t1 (2)", Query]
58+
include/assert.inc [INFORMATION_SCHEMA.processlist reports: db=test, info LIKE "DELETE FROM test.t1 (2)", command=Query]
59+
[SHOW PROCESSLIST reports: db=test, info LIKE "DELETE FROM test.t1 (2)", command=Query]
6060
SET debug_sync= 'now SIGNAL signal.rpl_row_apply_process_next_row';
6161
check on channel_3
6262
include/start_slave_sql.inc [FOR CHANNEL 'channel_3']
6363
SET debug_sync= 'now WAIT_FOR signal.rpl_row_apply_progress_updated';
64-
include/assert.inc [PERFORMANCE_SCHEMA.threads reports: state=Applying batch of row changes (write), db=test, info LIKE "INSERT INTO t1 VALUES (1)", Query]
65-
include/assert.inc [INFORMATION_SCHEMA.processlist reports: db=test, info LIKE "INSERT INTO t1 VALUES (1)", command=Query]
66-
[SHOW PROCESSLIST reports: db=test, info LIKE "INSERT INTO t1 VALUES (1)", command=Query]
64+
include/assert.inc [PERFORMANCE_SCHEMA.threads reports: state=Applying batch of row changes (write), db=test, info LIKE "INSERT INTO test.t1 (1)", Query]
65+
include/assert.inc [INFORMATION_SCHEMA.processlist reports: db=test, info LIKE "INSERT INTO test.t1 (1)", command=Query]
66+
[SHOW PROCESSLIST reports: db=test, info LIKE "INSERT INTO test.t1 (1)", command=Query]
6767
SET debug_sync= 'now SIGNAL signal.rpl_row_apply_process_next_row';
6868
SET debug_sync= 'now WAIT_FOR signal.rpl_row_apply_progress_updated';
69-
include/assert.inc [PERFORMANCE_SCHEMA.threads reports: state=Applying batch of row changes (update), db=test, info LIKE "UPDATE t1 SET a= 2", Query]
70-
include/assert.inc [INFORMATION_SCHEMA.processlist reports: db=test, info LIKE "UPDATE t1 SET a= 2", command=Query]
71-
[SHOW PROCESSLIST reports: db=test, info LIKE "UPDATE t1 SET a= 2", command=Query]
69+
include/assert.inc [PERFORMANCE_SCHEMA.threads reports: state=Applying batch of row changes (update), db=test, info LIKE "UPDATE test.t1 (1)(2)", Query]
70+
include/assert.inc [INFORMATION_SCHEMA.processlist reports: db=test, info LIKE "UPDATE test.t1 (1)(2)", command=Query]
71+
[SHOW PROCESSLIST reports: db=test, info LIKE "UPDATE test.t1 (1)(2)", command=Query]
7272
SET debug_sync= 'now SIGNAL signal.rpl_row_apply_process_next_row';
7373
SET debug_sync= 'now WAIT_FOR signal.rpl_row_apply_progress_updated';
74-
include/assert.inc [PERFORMANCE_SCHEMA.threads reports: state=Applying batch of row changes (delete), db=test, info LIKE "DELETE FROM t1 WHERE a=2", Query]
75-
include/assert.inc [INFORMATION_SCHEMA.processlist reports: db=test, info LIKE "DELETE FROM t1 WHERE a=2", command=Query]
76-
[SHOW PROCESSLIST reports: db=test, info LIKE "DELETE FROM t1 WHERE a=2", command=Query]
74+
include/assert.inc [PERFORMANCE_SCHEMA.threads reports: state=Applying batch of row changes (delete), db=test, info LIKE "DELETE FROM test.t1 (2)", Query]
75+
include/assert.inc [INFORMATION_SCHEMA.processlist reports: db=test, info LIKE "DELETE FROM test.t1 (2)", command=Query]
76+
[SHOW PROCESSLIST reports: db=test, info LIKE "DELETE FROM test.t1 (2)", command=Query]
7777
SET debug_sync= 'now SIGNAL signal.rpl_row_apply_process_next_row';
7878
# Removing debug point 'dbug.rpl_apply_sync_barrier' from @@GLOBAL.debug
7979
[connection server_1]

Diff for: ‎mysql-test/suite/rpl/r/rpl_row_stages.result

+33-33
Original file line numberDiff line numberDiff line change
@@ -20,19 +20,19 @@ COMMIT;
2020
# Adding debug point 'dbug.rpl_apply_sync_barrier' to @@GLOBAL.debug
2121
include/start_slave_sql.inc
2222
SET debug_sync= 'now WAIT_FOR signal.rpl_row_apply_progress_updated';
23-
include/assert.inc [PERFORMANCE_SCHEMA.threads reports: state=Applying batch of row changes (write), db=db_wl7364, info LIKE "INSERT INTO t1 VALUES (1)", Query]
24-
include/assert.inc [INFORMATION_SCHEMA.processlist reports: db=db_wl7364, info LIKE "INSERT INTO t1 VALUES (1)", command=Query]
25-
[SHOW PROCESSLIST reports: db=db_wl7364, info LIKE "INSERT INTO t1 VALUES (1)", command=Query]
23+
include/assert.inc [PERFORMANCE_SCHEMA.threads reports: state=Applying batch of row changes (write), db=db_wl7364, info LIKE "INSERT INTO db_wl7364.t1 (1)", Query]
24+
include/assert.inc [INFORMATION_SCHEMA.processlist reports: db=db_wl7364, info LIKE "INSERT INTO db_wl7364.t1 (1)", command=Query]
25+
[SHOW PROCESSLIST reports: db=db_wl7364, info LIKE "INSERT INTO db_wl7364.t1 (1)", command=Query]
2626
SET debug_sync= 'now SIGNAL signal.rpl_row_apply_process_next_row';
2727
SET debug_sync= 'now WAIT_FOR signal.rpl_row_apply_progress_updated';
28-
include/assert.inc [PERFORMANCE_SCHEMA.threads reports: state=Applying batch of row changes (update), db=db_wl7364, info LIKE "UPDATE t1 SET c1= 2", Query]
29-
include/assert.inc [INFORMATION_SCHEMA.processlist reports: db=db_wl7364, info LIKE "UPDATE t1 SET c1= 2", command=Query]
30-
[SHOW PROCESSLIST reports: db=db_wl7364, info LIKE "UPDATE t1 SET c1= 2", command=Query]
28+
include/assert.inc [PERFORMANCE_SCHEMA.threads reports: state=Applying batch of row changes (update), db=db_wl7364, info LIKE "UPDATE db_wl7364.t1 (1)(2)", Query]
29+
include/assert.inc [INFORMATION_SCHEMA.processlist reports: db=db_wl7364, info LIKE "UPDATE db_wl7364.t1 (1)(2)", command=Query]
30+
[SHOW PROCESSLIST reports: db=db_wl7364, info LIKE "UPDATE db_wl7364.t1 (1)(2)", command=Query]
3131
SET debug_sync= 'now SIGNAL signal.rpl_row_apply_process_next_row';
3232
SET debug_sync= 'now WAIT_FOR signal.rpl_row_apply_progress_updated';
33-
include/assert.inc [PERFORMANCE_SCHEMA.threads reports: state=Applying batch of row changes (delete), db=db_wl7364, info LIKE "DELETE FROM t1 WHERE c1=2", Query]
34-
include/assert.inc [INFORMATION_SCHEMA.processlist reports: db=db_wl7364, info LIKE "DELETE FROM t1 WHERE c1=2", command=Query]
35-
[SHOW PROCESSLIST reports: db=db_wl7364, info LIKE "DELETE FROM t1 WHERE c1=2", command=Query]
33+
include/assert.inc [PERFORMANCE_SCHEMA.threads reports: state=Applying batch of row changes (delete), db=db_wl7364, info LIKE "DELETE FROM db_wl7364.t1 (2)", Query]
34+
include/assert.inc [INFORMATION_SCHEMA.processlist reports: db=db_wl7364, info LIKE "DELETE FROM db_wl7364.t1 (2)", command=Query]
35+
[SHOW PROCESSLIST reports: db=db_wl7364, info LIKE "DELETE FROM db_wl7364.t1 (2)", command=Query]
3636
SET debug_sync= 'now SIGNAL signal.rpl_row_apply_process_next_row';
3737
[connection master]
3838
SET @@SESSION.BINLOG_ROWS_QUERY_LOG_EVENTS=0;
@@ -50,19 +50,19 @@ COMMIT;
5050
# Adding debug point 'dbug.rpl_apply_sync_barrier' to @@GLOBAL.debug
5151
include/start_slave_sql.inc
5252
SET debug_sync= 'now WAIT_FOR signal.rpl_row_apply_progress_updated';
53-
include/assert.inc [PERFORMANCE_SCHEMA.threads reports: state=Applying batch of row changes (write), db=db_wl7364, info IS NULL, Query]
54-
include/assert.inc [INFORMATION_SCHEMA.processlist reports: db=db_wl7364, info IS NULL, command=Query]
55-
[SHOW PROCESSLIST reports: db=db_wl7364, info LIKE 'NULL', command=Query]
53+
include/assert.inc [PERFORMANCE_SCHEMA.threads reports: state=Applying batch of row changes (write), db=db_wl7364, info LIKE "INSERT INTO db_wl7364.t1 (1)", Query]
54+
include/assert.inc [INFORMATION_SCHEMA.processlist reports: db=db_wl7364, info LIKE "INSERT INTO db_wl7364.t1 (1)", command=Query]
55+
[SHOW PROCESSLIST reports: db=db_wl7364, info LIKE "INSERT INTO db_wl7364.t1 (1)", command=Query]
5656
SET debug_sync= 'now SIGNAL signal.rpl_row_apply_process_next_row';
5757
SET debug_sync= 'now WAIT_FOR signal.rpl_row_apply_progress_updated';
58-
include/assert.inc [PERFORMANCE_SCHEMA.threads reports: state=Applying batch of row changes (update), db=db_wl7364, info IS NULL, Query]
59-
include/assert.inc [INFORMATION_SCHEMA.processlist reports: db=db_wl7364, info IS NULL, command=Query]
60-
[SHOW PROCESSLIST reports: db=db_wl7364, info LIKE 'NULL', command=Query]
58+
include/assert.inc [PERFORMANCE_SCHEMA.threads reports: state=Applying batch of row changes (update), db=db_wl7364, info LIKE "UPDATE db_wl7364.t1 (1)(2)", Query]
59+
include/assert.inc [INFORMATION_SCHEMA.processlist reports: db=db_wl7364, info LIKE "UPDATE db_wl7364.t1 (1)(2)", command=Query]
60+
[SHOW PROCESSLIST reports: db=db_wl7364, info LIKE "UPDATE db_wl7364.t1 (1)(2)", command=Query]
6161
SET debug_sync= 'now SIGNAL signal.rpl_row_apply_process_next_row';
6262
SET debug_sync= 'now WAIT_FOR signal.rpl_row_apply_progress_updated';
63-
include/assert.inc [PERFORMANCE_SCHEMA.threads reports: state=Applying batch of row changes (delete), db=db_wl7364, info IS NULL, Query]
64-
include/assert.inc [INFORMATION_SCHEMA.processlist reports: db=db_wl7364, info IS NULL, command=Query]
65-
[SHOW PROCESSLIST reports: db=db_wl7364, info LIKE 'NULL', command=Query]
63+
include/assert.inc [PERFORMANCE_SCHEMA.threads reports: state=Applying batch of row changes (delete), db=db_wl7364, info LIKE "DELETE FROM db_wl7364.t1 (2)", Query]
64+
include/assert.inc [INFORMATION_SCHEMA.processlist reports: db=db_wl7364, info LIKE "DELETE FROM db_wl7364.t1 (2)", command=Query]
65+
[SHOW PROCESSLIST reports: db=db_wl7364, info LIKE "DELETE FROM db_wl7364.t1 (2)", command=Query]
6666
SET debug_sync= 'now SIGNAL signal.rpl_row_apply_process_next_row';
6767
# Removing debug point 'dbug.rpl_apply_sync_barrier' from @@GLOBAL.debug
6868
[connection master]
@@ -81,22 +81,22 @@ BEGIN;
8181
BINLOG 'mSKWVhMBAAAAMgAAAOYCAAAAAPAAAAAAAAEACWRiX3dsNzM2NAACdDEAAQMAAfg9wnk=mSKWVh4BAAAAKAAAAA4DAAAAAPAAAAAAAAEAAgAB//4BAAAAnirPSw==';
8282
[connection master]
8383
SET debug_sync= 'now WAIT_FOR signal.rpl_row_apply_progress_updated';
84-
include/assert.inc [PERFORMANCE_SCHEMA.threads reports: state=Applying batch of row changes (write), db=db_wl7364, info LIKE "BINLOG %", Query]
85-
include/assert.inc [INFORMATION_SCHEMA.processlist reports: db=db_wl7364, info LIKE "BINLOG %", command=Query]
84+
include/assert.inc [PERFORMANCE_SCHEMA.threads reports: state=Applying batch of row changes (write), db=db_wl7364, info LIKE "INSERT INTO db_wl7364.t1 (1)", Query]
85+
include/assert.inc [INFORMATION_SCHEMA.processlist reports: db=db_wl7364, info LIKE "INSERT INTO db_wl7364.t1 (1)", command=Query]
8686
SET debug_sync= 'now SIGNAL signal.rpl_row_apply_process_next_row';
8787
[connection master1]
8888
BINLOG 'mSKWVhMBAAAAMgAAAGsDAAAAAPAAAAAAAAEACWRiX3dsNzM2NAACdDEAAQMAAWFoKHE=mSKWVh8BAAAALgAAAJkDAAAAAPAAAAAAAAEAAgAB///+AQAAAP4CAAAAuiHqhw==';
8989
[connection master]
9090
SET debug_sync= 'now WAIT_FOR signal.rpl_row_apply_progress_updated';
91-
include/assert.inc [PERFORMANCE_SCHEMA.threads reports: state=Applying batch of row changes (update), db=db_wl7364, info LIKE "BINLOG %", Query]
92-
include/assert.inc [INFORMATION_SCHEMA.processlist reports: db=db_wl7364, info LIKE "BINLOG %", command=Query]
91+
include/assert.inc [PERFORMANCE_SCHEMA.threads reports: state=Applying batch of row changes (update), db=db_wl7364, info LIKE "UPDATE db_wl7364.t1 (1)(2)", Query]
92+
include/assert.inc [INFORMATION_SCHEMA.processlist reports: db=db_wl7364, info LIKE "UPDATE db_wl7364.t1 (1)(2)", command=Query]
9393
SET debug_sync= 'now SIGNAL signal.rpl_row_apply_process_next_row';
9494
[connection master1]
9595
BINLOG 'mSKWVhMBAAAAMgAAAPwDAAAAAPAAAAAAAAEACWRiX3dsNzM2NAACdDEAAQMAAd+b01A=mSKWViABAAAAKAAAACQEAAAAAPAAAAAAAAEAAgAB//4CAAAAN7fZXg== ';
9696
[connection master]
9797
SET debug_sync= 'now WAIT_FOR signal.rpl_row_apply_progress_updated';
98-
include/assert.inc [PERFORMANCE_SCHEMA.threads reports: state=Applying batch of row changes (delete), db=db_wl7364, info LIKE "BINLOG %", Query]
99-
include/assert.inc [INFORMATION_SCHEMA.processlist reports: db=db_wl7364, info LIKE "BINLOG %", command=Query]
98+
include/assert.inc [PERFORMANCE_SCHEMA.threads reports: state=Applying batch of row changes (delete), db=db_wl7364, info LIKE "DELETE FROM db_wl7364.t1 (2)", Query]
99+
include/assert.inc [INFORMATION_SCHEMA.processlist reports: db=db_wl7364, info LIKE "DELETE FROM db_wl7364.t1 (2)", command=Query]
100100
SET debug_sync= 'now SIGNAL signal.rpl_row_apply_process_next_row';
101101
[connection master1]
102102
COMMIT;
@@ -221,19 +221,19 @@ COMMIT;
221221
# Adding debug point 'dbug.rpl_apply_sync_barrier' to @@GLOBAL.debug
222222
include/start_slave_sql.inc
223223
SET debug_sync= 'now WAIT_FOR signal.rpl_row_apply_progress_updated';
224-
include/assert.inc [PERFORMANCE_SCHEMA.threads reports: state=Applying batch of row changes (write), db=db2, info LIKE "INSERT INTO t1 VALUES (1)", Query]
225-
include/assert.inc [INFORMATION_SCHEMA.processlist reports: db=db2, info LIKE "INSERT INTO t1 VALUES (1)", command=Query]
226-
[SHOW PROCESSLIST reports: db=db2, info LIKE "INSERT INTO t1 VALUES (1)", command=Query]
224+
include/assert.inc [PERFORMANCE_SCHEMA.threads reports: state=Applying batch of row changes (write), db=db2, info LIKE "INSERT INTO db2.t1 (1)", Query]
225+
include/assert.inc [INFORMATION_SCHEMA.processlist reports: db=db2, info LIKE "INSERT INTO db2.t1 (1)", command=Query]
226+
[SHOW PROCESSLIST reports: db=db2, info LIKE "INSERT INTO db2.t1 (1)", command=Query]
227227
SET debug_sync= 'now SIGNAL signal.rpl_row_apply_process_next_row';
228228
SET debug_sync= 'now WAIT_FOR signal.rpl_row_apply_progress_updated';
229-
include/assert.inc [PERFORMANCE_SCHEMA.threads reports: state=Applying batch of row changes (update), db=db2, info LIKE "UPDATE t1 SET c1= 2", Query]
230-
include/assert.inc [INFORMATION_SCHEMA.processlist reports: db=db2, info LIKE "UPDATE t1 SET c1= 2", command=Query]
231-
[SHOW PROCESSLIST reports: db=db2, info LIKE "UPDATE t1 SET c1= 2", command=Query]
229+
include/assert.inc [PERFORMANCE_SCHEMA.threads reports: state=Applying batch of row changes (update), db=db2, info LIKE "UPDATE db2.t1 (1)(2)", Query]
230+
include/assert.inc [INFORMATION_SCHEMA.processlist reports: db=db2, info LIKE "UPDATE db2.t1 (1)(2)", command=Query]
231+
[SHOW PROCESSLIST reports: db=db2, info LIKE "UPDATE db2.t1 (1)(2)", command=Query]
232232
SET debug_sync= 'now SIGNAL signal.rpl_row_apply_process_next_row';
233233
SET debug_sync= 'now WAIT_FOR signal.rpl_row_apply_progress_updated';
234-
include/assert.inc [PERFORMANCE_SCHEMA.threads reports: state=Applying batch of row changes (delete), db=db2, info LIKE "DELETE FROM t1 WHERE c1=2", Query]
235-
include/assert.inc [INFORMATION_SCHEMA.processlist reports: db=db2, info LIKE "DELETE FROM t1 WHERE c1=2", command=Query]
236-
[SHOW PROCESSLIST reports: db=db2, info LIKE "DELETE FROM t1 WHERE c1=2", command=Query]
234+
include/assert.inc [PERFORMANCE_SCHEMA.threads reports: state=Applying batch of row changes (delete), db=db2, info LIKE "DELETE FROM db2.t1 (2)", Query]
235+
include/assert.inc [INFORMATION_SCHEMA.processlist reports: db=db2, info LIKE "DELETE FROM db2.t1 (2)", command=Query]
236+
[SHOW PROCESSLIST reports: db=db2, info LIKE "DELETE FROM db2.t1 (2)", command=Query]
237237
SET debug_sync= 'now SIGNAL signal.rpl_row_apply_process_next_row';
238238
[connection slave]
239239
# Removing debug point 'dbug.rpl_apply_sync_barrier' from @@GLOBAL.debug

Diff for: ‎mysql-test/suite/rpl/t/rpl_multi_source_row_stages-slave.opt

+1
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
--slave_parallel_workers=0

Diff for: ‎mysql-test/suite/rpl/t/rpl_multi_source_row_stages.test

+3-3
Original file line numberDiff line numberDiff line change
@@ -114,17 +114,17 @@ while ($j)
114114
if ($i == 3)
115115
{
116116
--let $state_progress= Applying batch of row changes (write)
117-
--let $info= INSERT INTO t1 VALUES (1)
117+
--let $info= INSERT INTO test.t1 (1)
118118
}
119119
if ($i == 2)
120120
{
121121
--let $state_progress= Applying batch of row changes (update)
122-
--let $info= UPDATE t1 SET a= 2
122+
--let $info= UPDATE test.t1 (1)(2)
123123
}
124124
if ($i == 1)
125125
{
126126
--let $state_progress= Applying batch of row changes (delete)
127-
--let $info= DELETE FROM t1 WHERE a=2
127+
--let $info= DELETE FROM test.t1 (2)
128128
}
129129

130130
# this session waits for the progress to be updated

Diff for: ‎mysql-test/suite/rpl/t/rpl_row_stages-slave.opt

+1
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
--slave_parallel_workers=0

0 commit comments

Comments
 (0)