From 9443d2640970ca700591478b9c4fe686497bc3f0 Mon Sep 17 00:00:00 2001
From: GMHDBJD <35025882+GMHDBJD@users.noreply.github.com>
Date: Fri, 5 Aug 2022 11:12:06 +0800
Subject: [PATCH] test(dm): fix unstable DM_RESYNC_NOT_FLUSHED_CASE (#6593)

ref pingcap/tiflow#4159
---
 dm/tests/shardddl4_1/run.sh | 15 ++++++++++++++-
 1 file changed, 14 insertions(+), 1 deletion(-)

diff --git a/dm/tests/shardddl4_1/run.sh b/dm/tests/shardddl4_1/run.sh
index 91c1e04a625..faa83aefb80 100644
--- a/dm/tests/shardddl4_1/run.sh
+++ b/dm/tests/shardddl4_1/run.sh
@@ -1174,6 +1174,19 @@ function DM_RESYNC_NOT_FLUSHED_CASE() {
 		sleep 1
 	done
 
+	check_log_contain_with_retry "receive redirection operation from master" $WORK_DIR/worker1/log/dm-worker.log
+	check_log_contain_with_retry "receive redirection operation from master" $WORK_DIR/worker2/log/dm-worker.log
+	for ((k = 140; k < 160; k++)); do
+		run_sql_source1 "insert into ${shardddl1}.${tb1} values(${k},${k},${k});"
+		k=$((k + 1))
+		run_sql_source1 "insert into ${shardddl1}.${tb2} values(${k},${k},${k});"
+		k=$((k + 1))
+		run_sql_source2 "insert into ${shardddl1}.${tb1} values(${k},${k},${k});"
+		k=$((k + 1))
+		run_sql_source2 "insert into ${shardddl1}.${tb2} values(${k},${k});"
+		sleep 1
+	done
+
 	# lock finished at first time, both workers should exit
 	check_process_exit worker1 20
 	check_process_exit worker2 20
@@ -1189,7 +1202,7 @@ function DM_RESYNC_NOT_FLUSHED_CASE() {
 	run_sql_source2 "insert into ${shardddl1}.${tb1} values(35,35,35);"
 	run_sql_source2 "insert into ${shardddl1}.${tb2} values(36,36,36);"
 
-	for ((k = 200; k < 240; k++)); do
+	for ((k = 200; k < 280; k++)); do
 		run_sql_source1 "insert into ${shardddl1}.${tb1} values(${k},${k},${k});"
 		k=$((k + 1))
 		run_sql_source1 "insert into ${shardddl1}.${tb2} values(${k},${k},${k});"