Skip to content

Commit

Permalink
tests(ticdc): fix unstable test big_txn (#6062)
Browse files Browse the repository at this point in the history
close #6046
  • Loading branch information
CharlesCheung96 authored Jun 28, 2022
1 parent 6573fa8 commit a6bee9d
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion tests/integration_tests/big_txn/conf/workload
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
threadcount=1
recordcount=10000
recordcount=5000
operationcount=0
workload=core
fieldcount=100
Expand Down
2 changes: 1 addition & 1 deletion tests/integration_tests/big_txn/run.sh
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand All @@ -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"
Expand Down

0 comments on commit a6bee9d

Please sign in to comment.