diff --git a/ci/scripts/e2e-iceberg-cdc.sh b/ci/scripts/e2e-iceberg-cdc.sh index 1cdc4abf26487..62781d0759278 100755 --- a/ci/scripts/e2e-iceberg-cdc.sh +++ b/ci/scripts/e2e-iceberg-cdc.sh @@ -52,6 +52,8 @@ bash ./start_spark_connect_server.sh # 1. import data to mysql mysql --host=mysql --port=3306 -u root -p123456 < ./test_case/cdc/mysql_cdc.sql +sleep 10 + # 2. create table and sink "$HOME"/.local/bin/poetry run python main.py -t ./test_case/cdc/no_partition_cdc_init.toml diff --git a/e2e_test/iceberg/test_case/cdc/load.slt b/e2e_test/iceberg/test_case/cdc/load.slt index 2ac8ab2d61f25..e053fd82efb63 100644 --- a/e2e_test/iceberg/test_case/cdc/load.slt +++ b/e2e_test/iceberg/test_case/cdc/load.slt @@ -38,6 +38,8 @@ CREATE SINK s1 AS select * from products WITH ( statement ok flush; +sleep 10s + query I select count(*) from products; ----