Skip to content

Commit

Permalink
fix make fmt
Browse files Browse the repository at this point in the history
  • Loading branch information
3AceShowHand committed Nov 1, 2023
1 parent a364530 commit aa2f0ab
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions tests/integration_tests/kafka_column_selector/run.sh
Original file line number Diff line number Diff line change
Expand Up @@ -24,14 +24,14 @@ function run() {

run_cdc_server --workdir $WORK_DIR --binary $CDC_BINARY

changefeed_id="test"
TOPIC_NAME = "column-selector-test"
changefeed_id="test"
TOPIC_NAME = "column-selector-test"
SINK_URI="kafka://127.0.0.1:9092/$TOPIC_NAME?protocol=canal-json&partition-num=1&enable-tidb-extension=true"
run_cdc_cli changefeed create --start-ts=$start_ts --sink-uri="$SINK_URI" -c ${changefeed_id} --config="$CUR/conf/changefeed.toml"

cdc_kafka_consumer --upstream-uri $SINK_URI --downstream-uri="mysql://[email protected]:3306/?safe-mode=true&batch-dml-enable=false" --upstream-tidb-dsn="root@tcp(${UP_TIDB_HOST}:${UP_TIDB_PORT})/?" --config="$CUR/conf/changefeed.toml" 2>&1 &

run_sql_file $CUR/data/data.sql ${UP_TIDB_HOST} ${UP_TIDB_PORT}
run_sql_file $CUR/data/data.sql ${UP_TIDB_HOST} ${UP_TIDB_PORT}

echo "Starting build checksum checker..."
cd $CUR/../../utils/checksum_checker
Expand All @@ -41,7 +41,7 @@ function run() {

check_table_exists "test1.finishmark" ${DOWN_TIDB_HOST} ${DOWN_TIDB_PORT}

./checksum_checker --upstream-uri "root@tcp(${UP_TIDB_HOST}:${UP_TIDB_PORT})/" --downstream-uri "root@tcp(${DOWN_TIDB_HOST}:${DOWN_TIDB_PORT})/" --databases "test,test1" --config="$CUR/conf/changefeed.toml"
./checksum_checker --upstream-uri "root@tcp(${UP_TIDB_HOST}:${UP_TIDB_PORT})/" --downstream-uri "root@tcp(${DOWN_TIDB_HOST}:${DOWN_TIDB_PORT})/" --databases "test,test1" --config="$CUR/conf/changefeed.toml"

cleanup_process $CDC_BINARY
}
Expand Down

0 comments on commit aa2f0ab

Please sign in to comment.