Commit 024e9512 authored by Jan Lindström's avatar Jan Lindström Committed by Julius Goryavsky

MDEV-32996 : galera.galera_var_ignore_apply_errors -> [ERROR] WSREP: Inconsistency detected

Add wait_until_ready waits after wsrep_on is set on again to
make sure that node is ready for next step before continuing.
Signed-off-by: default avatarJulius Goryavsky <julius.goryavsky@mariadb.com>
parent 0ce5603b
...@@ -208,7 +208,9 @@ DROP TABLE t1; ...@@ -208,7 +208,9 @@ DROP TABLE t1;
connection node_2; connection node_2;
SELECT * FROM t1; SELECT * FROM t1;
ERROR 42S02: Table 'test.t1' doesn't exist ERROR 42S02: Table 'test.t1' doesn't exist
SET GLOBAL wsrep_ignore_apply_errors = 7; SET GLOBAL wsrep_ignore_apply_errors = 10;
Warnings:
Warning 1292 Truncated incorrect wsrep_ignore_apply_errors value: '10'
CALL mtr.add_suppression("Can't find record in "); CALL mtr.add_suppression("Can't find record in ");
CALL mtr.add_suppression("Slave SQL: Could not execute Delete_rows event"); CALL mtr.add_suppression("Slave SQL: Could not execute Delete_rows event");
CALL mtr.add_suppression("Slave SQL: Error 'Unknown table 'test\\.t1'' on query\\. Default database: 'test'\\. Query: 'DROP TABLE t1', Error_code: 1051"); CALL mtr.add_suppression("Slave SQL: Error 'Unknown table 'test\\.t1'' on query\\. Default database: 'test'\\. Query: 'DROP TABLE t1', Error_code: 1051");
...@@ -217,3 +219,4 @@ CALL mtr.add_suppression("Slave SQL: Error 'Can't DROP 'idx1'; check that column ...@@ -217,3 +219,4 @@ CALL mtr.add_suppression("Slave SQL: Error 'Can't DROP 'idx1'; check that column
CALL mtr.add_suppression("Slave SQL: Error 'Can't DROP 'idx1'; check that column/key exists' on query\\. Default database: 'test'\\. Query: 'ALTER TABLE t1 DROP INDEX idx1', Error_code: 1091"); CALL mtr.add_suppression("Slave SQL: Error 'Can't DROP 'idx1'; check that column/key exists' on query\\. Default database: 'test'\\. Query: 'ALTER TABLE t1 DROP INDEX idx1', Error_code: 1091");
CALL mtr.add_suppression("Slave SQL: Error 'Can't DROP 'f2'; check that column/key exists' on query\\. Default database: 'test'\\. Query: 'ALTER TABLE t1 DROP COLUMN f2', Error_code: 1091"); CALL mtr.add_suppression("Slave SQL: Error 'Can't DROP 'f2'; check that column/key exists' on query\\. Default database: 'test'\\. Query: 'ALTER TABLE t1 DROP COLUMN f2', Error_code: 1091");
CALL mtr.add_suppression("Slave SQL: Error 'Table 't1' already exists' on query\\."); CALL mtr.add_suppression("Slave SQL: Error 'Table 't1' already exists' on query\\.");
CALL mtr.add_suppression("Inconsistency detected: Inconsistent by consensus on ");
...@@ -2,5 +2,5 @@ ...@@ -2,5 +2,5 @@
[mysqld] [mysqld]
wsrep_debug=1 wsrep_debug=1
wsrep_sync_wait=15 wsrep_sync_wait=0
loose-galera-var-ignore-apply-errors=1 loose-galera-var-ignore-apply-errors=1
...@@ -17,6 +17,7 @@ SET GLOBAL wsrep_ignore_apply_errors = 1; ...@@ -17,6 +17,7 @@ SET GLOBAL wsrep_ignore_apply_errors = 1;
SET GLOBAL wsrep_on = OFF; SET GLOBAL wsrep_on = OFF;
CREATE TABLE t1 (f1 INTEGER); CREATE TABLE t1 (f1 INTEGER);
SET GLOBAL wsrep_on = ON; SET GLOBAL wsrep_on = ON;
--source include/wait_until_ready.inc
DROP TABLE t1; DROP TABLE t1;
--connection node_2 --connection node_2
...@@ -27,6 +28,7 @@ SHOW TABLES; ...@@ -27,6 +28,7 @@ SHOW TABLES;
SET GLOBAL wsrep_on = OFF; SET GLOBAL wsrep_on = OFF;
CREATE SCHEMA s1; CREATE SCHEMA s1;
SET GLOBAL wsrep_on = ON; SET GLOBAL wsrep_on = ON;
--source include/wait_until_ready.inc
DROP SCHEMA s1; DROP SCHEMA s1;
--connection node_2 --connection node_2
...@@ -38,6 +40,7 @@ CREATE TABLE t1 (f1 INTEGER); ...@@ -38,6 +40,7 @@ CREATE TABLE t1 (f1 INTEGER);
SET GLOBAL wsrep_on = OFF; SET GLOBAL wsrep_on = OFF;
CREATE INDEX idx1 ON t1 (f1); CREATE INDEX idx1 ON t1 (f1);
SET GLOBAL wsrep_on = ON; SET GLOBAL wsrep_on = ON;
--source include/wait_until_ready.inc
DROP INDEX idx1 ON t1; DROP INDEX idx1 ON t1;
--connection node_2 --connection node_2
...@@ -50,6 +53,7 @@ CREATE TABLE t1 (f1 INTEGER); ...@@ -50,6 +53,7 @@ CREATE TABLE t1 (f1 INTEGER);
SET GLOBAL wsrep_on = OFF; SET GLOBAL wsrep_on = OFF;
CREATE INDEX idx1 ON t1 (f1); CREATE INDEX idx1 ON t1 (f1);
SET GLOBAL wsrep_on = ON; SET GLOBAL wsrep_on = ON;
--source include/wait_until_ready.inc
ALTER TABLE t1 DROP INDEX idx1; ALTER TABLE t1 DROP INDEX idx1;
--connection node_2 --connection node_2
...@@ -62,6 +66,7 @@ CREATE TABLE t1 (f1 INTEGER); ...@@ -62,6 +66,7 @@ CREATE TABLE t1 (f1 INTEGER);
SET GLOBAL wsrep_on = OFF; SET GLOBAL wsrep_on = OFF;
ALTER TABLE t1 ADD COLUMN f2 INTEGER; ALTER TABLE t1 ADD COLUMN f2 INTEGER;
SET GLOBAL wsrep_on = ON; SET GLOBAL wsrep_on = ON;
--source include/wait_until_ready.inc
ALTER TABLE t1 DROP COLUMN f2; ALTER TABLE t1 DROP COLUMN f2;
--connection node_2 --connection node_2
...@@ -82,6 +87,7 @@ CREATE TABLE t1 (f1 INTEGER); ...@@ -82,6 +87,7 @@ CREATE TABLE t1 (f1 INTEGER);
SET GLOBAL wsrep_on = OFF; SET GLOBAL wsrep_on = OFF;
INSERT INTO t1 VALUES (1); INSERT INTO t1 VALUES (1);
SET GLOBAL wsrep_on = ON; SET GLOBAL wsrep_on = ON;
--source include/wait_until_ready.inc
DELETE FROM t1 WHERE f1 = 1; DELETE FROM t1 WHERE f1 = 1;
SELECT COUNT(*) AS expect_0 FROM t1; SELECT COUNT(*) AS expect_0 FROM t1;
...@@ -96,6 +102,7 @@ INSERT INTO t1 VALUES (2); ...@@ -96,6 +102,7 @@ INSERT INTO t1 VALUES (2);
SET GLOBAL wsrep_on = OFF; SET GLOBAL wsrep_on = OFF;
INSERT INTO t1 VALUES (1); INSERT INTO t1 VALUES (1);
SET GLOBAL wsrep_on = ON; SET GLOBAL wsrep_on = ON;
--source include/wait_until_ready.inc
START TRANSACTION; START TRANSACTION;
INSERT INTO t1 VALUES (3); INSERT INTO t1 VALUES (3);
DELETE FROM t1 WHERE f1 = 1; DELETE FROM t1 WHERE f1 = 1;
...@@ -121,6 +128,7 @@ INSERT INTO t1 VALUES (1),(2),(3),(4),(5); ...@@ -121,6 +128,7 @@ INSERT INTO t1 VALUES (1),(2),(3),(4),(5);
SET SESSION wsrep_on = OFF; SET SESSION wsrep_on = OFF;
DELETE FROM t1 WHERE f1 = 3; DELETE FROM t1 WHERE f1 = 3;
SET SESSION wsrep_on = ON; SET SESSION wsrep_on = ON;
--source include/wait_until_ready.inc
--connection node_1 --connection node_1
DELETE FROM t1; DELETE FROM t1;
...@@ -147,6 +155,7 @@ INSERT INTO t1 VALUES (1),(2),(3),(4),(5); ...@@ -147,6 +155,7 @@ INSERT INTO t1 VALUES (1),(2),(3),(4),(5);
SET SESSION wsrep_on = OFF; SET SESSION wsrep_on = OFF;
DELETE FROM t1 WHERE f1 = 3; DELETE FROM t1 WHERE f1 = 3;
SET SESSION wsrep_on = ON; SET SESSION wsrep_on = ON;
--source include/wait_until_ready.inc
--connection node_1 --connection node_1
SET AUTOCOMMIT=OFF; SET AUTOCOMMIT=OFF;
...@@ -185,6 +194,7 @@ SET SESSION wsrep_on = OFF; ...@@ -185,6 +194,7 @@ SET SESSION wsrep_on = OFF;
DELETE FROM t2 WHERE f1 = 2; DELETE FROM t2 WHERE f1 = 2;
DELETE FROM t1 WHERE f1 = 3; DELETE FROM t1 WHERE f1 = 3;
SET SESSION wsrep_on = ON; SET SESSION wsrep_on = ON;
--source include/wait_until_ready.inc
--connection node_1 --connection node_1
DELETE t1, t2 FROM t1 JOIN t2 WHERE t1.f1 = t2.f1; DELETE t1, t2 FROM t1 JOIN t2 WHERE t1.f1 = t2.f1;
...@@ -214,6 +224,7 @@ INSERT INTO child VALUES (1,1),(2,2),(3,3); ...@@ -214,6 +224,7 @@ INSERT INTO child VALUES (1,1),(2,2),(3,3);
SET SESSION wsrep_on = OFF; SET SESSION wsrep_on = OFF;
DELETE FROM child WHERE parent_id = 2; DELETE FROM child WHERE parent_id = 2;
SET SESSION wsrep_on = ON; SET SESSION wsrep_on = ON;
--source include/wait_until_ready.inc
--connection node_1 --connection node_1
DELETE FROM parent; DELETE FROM parent;
...@@ -240,6 +251,7 @@ SET GLOBAL wsrep_ignore_apply_errors = 4; ...@@ -240,6 +251,7 @@ SET GLOBAL wsrep_ignore_apply_errors = 4;
SET GLOBAL wsrep_on = OFF; SET GLOBAL wsrep_on = OFF;
CREATE TABLE t1 (f1 INTEGER); CREATE TABLE t1 (f1 INTEGER);
SET GLOBAL wsrep_on = ON; SET GLOBAL wsrep_on = ON;
--source include/wait_until_ready.inc
--connection node_1 --connection node_1
CREATE TABLE t1 (f1 INTEGER, f2 INTEGER); CREATE TABLE t1 (f1 INTEGER, f2 INTEGER);
...@@ -248,7 +260,7 @@ DROP TABLE t1; ...@@ -248,7 +260,7 @@ DROP TABLE t1;
--connection node_2 --connection node_2
--error ER_NO_SUCH_TABLE --error ER_NO_SUCH_TABLE
SELECT * FROM t1; SELECT * FROM t1;
SET GLOBAL wsrep_ignore_apply_errors = 7; SET GLOBAL wsrep_ignore_apply_errors = 10;
CALL mtr.add_suppression("Can't find record in "); CALL mtr.add_suppression("Can't find record in ");
CALL mtr.add_suppression("Slave SQL: Could not execute Delete_rows event"); CALL mtr.add_suppression("Slave SQL: Could not execute Delete_rows event");
...@@ -258,3 +270,4 @@ CALL mtr.add_suppression("Slave SQL: Error 'Can't DROP 'idx1'; check that column ...@@ -258,3 +270,4 @@ CALL mtr.add_suppression("Slave SQL: Error 'Can't DROP 'idx1'; check that column
CALL mtr.add_suppression("Slave SQL: Error 'Can't DROP 'idx1'; check that column/key exists' on query\\. Default database: 'test'\\. Query: 'ALTER TABLE t1 DROP INDEX idx1', Error_code: 1091"); CALL mtr.add_suppression("Slave SQL: Error 'Can't DROP 'idx1'; check that column/key exists' on query\\. Default database: 'test'\\. Query: 'ALTER TABLE t1 DROP INDEX idx1', Error_code: 1091");
CALL mtr.add_suppression("Slave SQL: Error 'Can't DROP 'f2'; check that column/key exists' on query\\. Default database: 'test'\\. Query: 'ALTER TABLE t1 DROP COLUMN f2', Error_code: 1091"); CALL mtr.add_suppression("Slave SQL: Error 'Can't DROP 'f2'; check that column/key exists' on query\\. Default database: 'test'\\. Query: 'ALTER TABLE t1 DROP COLUMN f2', Error_code: 1091");
CALL mtr.add_suppression("Slave SQL: Error 'Table 't1' already exists' on query\\."); CALL mtr.add_suppression("Slave SQL: Error 'Table 't1' already exists' on query\\.");
CALL mtr.add_suppression("Inconsistency detected: Inconsistent by consensus on ");
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment