From ac6f77b597c50f922957a4ceb677b7b69e5ff289 Mon Sep 17 00:00:00 2001 From: 3AceShowHand Date: Mon, 16 Oct 2023 10:53:39 +0800 Subject: [PATCH] fix integration test. --- tests/integration_tests/mq_sink_dispatcher/run.sh | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/tests/integration_tests/mq_sink_dispatcher/run.sh b/tests/integration_tests/mq_sink_dispatcher/run.sh index baa7b5f540e..d048b03f23c 100644 --- a/tests/integration_tests/mq_sink_dispatcher/run.sh +++ b/tests/integration_tests/mq_sink_dispatcher/run.sh @@ -39,6 +39,8 @@ function run() { run_sql "CREATE DATABASE dispatcher;" ${UP_TIDB_HOST} ${UP_TIDB_PORT} run_sql "CREATE TABLE dispatcher.index (a int primary key, b int);" ${UP_TIDB_HOST} ${UP_TIDB_PORT} + run_sql "INSERT INTO dispatcher.index values (1, 2);" ${UP_TIDB_HOST} ${UP_TIDB_PORT} + ensure $MAX_RETRIES check_changefeed_status 127.0.0.1:8300 $changefeed_id "failed" run_cdc_cli changefeed update -c ${changefeed_id} --sink-uri="$SINK_URI" --config="$CUR/conf/new_changefeed.toml" --no-confirm @@ -47,7 +49,6 @@ function run() { ensure $MAX_RETRIES check_changefeed_status 127.0.0.1:8300 $changefeed_id "normal" - run_sql "INSERT INTO dispatcher.index values (1, 2);" ${UP_TIDB_HOST} ${UP_TIDB_PORT} run_sql "INSERT INTO dispatcher.index values (2, 3);" ${UP_TIDB_HOST} ${UP_TIDB_PORT} run_sql "INSERT INTO dispatcher.index values (3, 4);" ${UP_TIDB_HOST} ${UP_TIDB_PORT} run_sql "INSERT INTO dispatcher.index values (4, 5);" ${UP_TIDB_HOST} ${UP_TIDB_PORT}