From a6bee9dda801569a9fdfe4467d221c8029b20909 Mon Sep 17 00:00:00 2001
From: CharlesCheung <61726649+CharlesCheung96@users.noreply.github.com>
Date: Tue, 28 Jun 2022 12:56:39 +0800
Subject: [PATCH] tests(ticdc): fix unstable test big_txn (#6062)

close pingcap/tiflow#6046
---
 tests/integration_tests/big_txn/conf/workload | 2 +-
 tests/integration_tests/big_txn/run.sh        | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/tests/integration_tests/big_txn/conf/workload b/tests/integration_tests/big_txn/conf/workload
index 23c9f38ed3f..d15d4a81bfd 100644
--- a/tests/integration_tests/big_txn/conf/workload
+++ b/tests/integration_tests/big_txn/conf/workload
@@ -1,5 +1,5 @@
 threadcount=1
-recordcount=10000
+recordcount=5000
 operationcount=0
 workload=core
 fieldcount=100
diff --git a/tests/integration_tests/big_txn/run.sh b/tests/integration_tests/big_txn/run.sh
index 9683f9f7c01..ee93cc5a757 100755
--- a/tests/integration_tests/big_txn/run.sh
+++ b/tests/integration_tests/big_txn/run.sh
@@ -18,6 +18,7 @@ function run() {
 
 	cd $WORK_DIR
 
+	run_cdc_server --workdir $WORK_DIR --binary $CDC_BINARY
 	start_ts=$(run_cdc_cli_tso_query ${UP_PD_HOST_1} ${UP_PD_PORT_1})
 	TOPIC_NAME="ticdc-big-txn-test-$RANDOM"
 	case $SINK_TYPE in
@@ -28,7 +29,6 @@ function run() {
 
 	run_sql "CREATE DATABASE big_txn;"
 	go-ycsb load mysql -P $CUR/conf/workload -p mysql.host=${UP_TIDB_HOST} -p mysql.port=${UP_TIDB_PORT} -p mysql.user=root -p mysql.db=big_txn
-	run_cdc_server --workdir $WORK_DIR --binary $CDC_BINARY
 
 	if [ "$SINK_TYPE" == "kafka" ]; then
 		run_kafka_consumer $WORK_DIR "kafka://127.0.0.1:9092/$TOPIC_NAME?protocol=open-protocol&partition-num=4&version=${KAFKA_VERSION}&max-message-bytes=10485760"