Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
StrikeW committed Jun 25, 2024
1 parent 44bebe4 commit 4b55d07
Show file tree
Hide file tree
Showing 3 changed files with 14 additions and 5 deletions.
5 changes: 2 additions & 3 deletions ci/scripts/e2e-source-test.sh
Original file line number Diff line number Diff line change
Expand Up @@ -36,9 +36,6 @@ python3 -m pip install --break-system-packages requests protobuf fastavro conflu

echo "--- e2e, inline test"
RUST_LOG="debug,risingwave_stream=info,risingwave_batch=info,risingwave_storage=info" \
export PGHOST=db PGPORT=5432 PGUSER=postgres PGPASSWORD=postgres PGDATABASE=cdc_test
export MYSQL_HOST=mysql MYSQL_TCP_PORT=3306 MYSQL_PWD=123456
createdb
risedev ci-start ci-inline-source-test
risedev slt './e2e_test/source_inline/**/*.slt'
echo "--- Kill cluster"
Expand All @@ -57,6 +54,8 @@ echo "--- e2e, ci-1cn-1fe, mysql & postgres cdc"
mysql --host=mysql --port=3306 -u root -p123456 < ./e2e_test/source/cdc/mysql_cdc.sql

# import data to postgres
export PGHOST=db PGPORT=5432 PGUSER=postgres PGPASSWORD=postgres PGDATABASE=cdc_test
createdb
psql < ./e2e_test/source/cdc/postgres_cdc.sql

echo "--- starting risingwave cluster"
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -212,3 +212,13 @@ select order_id, product_id, shipment_id from enriched_orders order by order_id;
10001 102 1001
10002 105 1002
10003 106 1003

statement ok
drop materialized view enriched_orders;

statement ok
drop source mysql_source cascade;

statement ok
drop source pg_source cascade;

4 changes: 2 additions & 2 deletions e2e_test/source/cdc_inline/alter/postgres_alter.slt
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,7 @@ INSERT INTO alter_test VALUES (3, 'c');
"

# FIXME: after schema change in RisingWave, why does it take so long to get the new data?
sleep 5s
sleep 20s

query ITT
SELECT * FROM alter_test ORDER BY k
Expand Down Expand Up @@ -72,7 +72,7 @@ INSERT INTO alter_test VALUES (5, 'ee');
"

# FIXME: after schema change in RisingWave, why does it take so long to get the new data?
sleep 5s
sleep 20s

query IT
SELECT * FROM alter_test ORDER BY k
Expand Down

0 comments on commit 4b55d07

Please sign in to comment.