diff --git a/ci/scripts/e2e-source-test.sh b/ci/scripts/e2e-source-test.sh index adb4c01187c6b..84fff651b547c 100755 --- a/ci/scripts/e2e-source-test.sh +++ b/ci/scripts/e2e-source-test.sh @@ -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" @@ -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" diff --git a/e2e_test/source_inline/cdc/alter/cdc_table_alter.slt b/e2e_test/source/cdc_inline/alter/cdc_table_alter.slt similarity index 97% rename from e2e_test/source_inline/cdc/alter/cdc_table_alter.slt rename to e2e_test/source/cdc_inline/alter/cdc_table_alter.slt index 931756cf8860b..d2a0abaeb4b70 100644 --- a/e2e_test/source_inline/cdc/alter/cdc_table_alter.slt +++ b/e2e_test/source/cdc_inline/alter/cdc_table_alter.slt @@ -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; + diff --git a/e2e_test/source/cdc_inline/alter/postgres_alter.slt b/e2e_test/source/cdc_inline/alter/postgres_alter.slt index 883dc669b03ca..807b6a152af54 100644 --- a/e2e_test/source/cdc_inline/alter/postgres_alter.slt +++ b/e2e_test/source/cdc_inline/alter/postgres_alter.slt @@ -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 @@ -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