diff --git a/tests/integration_tests/lossy_ddl/data/prepare.sql b/tests/integration_tests/lossy_ddl/data/prepare.sql index d224aaa846d..35aa7a193e9 100644 --- a/tests/integration_tests/lossy_ddl/data/prepare.sql +++ b/tests/integration_tests/lossy_ddl/data/prepare.sql @@ -164,6 +164,21 @@ INSERT INTO example15 (id, b) VALUES (1, -1); ALTER TABLE example15 MODIFY COLUMN b INT UNSIGNED; +-- exchange partition +CREATE TABLE example16 +( + a INT PRIMARY KEY +) PARTITION BY RANGE ( a ) ( PARTITION p0 VALUES LESS THAN (6),PARTITION p1 VALUES LESS THAN (11),PARTITION p2 VALUES LESS THAN (21)); +INSERT INTO example16 +VALUES (1); +CREATE TABLE example17 +( + a int primary key +); +INSERT INTO example17 +VALUES (18); +ALTER TABLE example16 EXCHANGE PARTITION p2 WITH TABLE example17; + CREATE TABLE `finish_mark` ( id INT PRIMARY KEY, diff --git a/tests/integration_tests/lossy_ddl/run.sh b/tests/integration_tests/lossy_ddl/run.sh index 1bd0bfd1d3a..d98a01ef029 100644 --- a/tests/integration_tests/lossy_ddl/run.sh +++ b/tests/integration_tests/lossy_ddl/run.sh @@ -23,8 +23,8 @@ function check_lossy_ddl() { row_logs=$(grep "BlackHoleSink: WriteEvents" "$1/cdc.log") echo $row_logs row_logs_count=$(grep "BlackHoleSink: WriteEvents" -c "$1/cdc.log") - if [[ "$row_logs_count" -ne 16 ]]; then - echo "can't found 16 row logs, got $row_logs_count" + if [[ "$row_logs_count" -ne 18 ]]; then + echo "can't found 18 row logs, got $row_logs_count" exit 1 fi }