diff --git a/ci/scripts/run-backfill-tests.sh b/ci/scripts/run-backfill-tests.sh index ac552cfcdcdd0..01b3fc1104b7f 100755 --- a/ci/scripts/run-backfill-tests.sh +++ b/ci/scripts/run-backfill-tests.sh @@ -185,9 +185,11 @@ test_sink_backfill_recovery() { # Check progress sqllogictest -p 4566 -d dev 'e2e_test/backfill/sink/create_sink.slt' + # Sleep before restart cluster, to ensure the downstream sink actually gets created. + sleep 10 + # Restart restart_cluster - sleep 5 # Sink back into rw run_sql "CREATE TABLE table_kafka (v1 int primary key) diff --git a/e2e_test/backfill/sink/create_sink.slt b/e2e_test/backfill/sink/create_sink.slt index 017eb8e693de2..d064f657c155f 100644 --- a/e2e_test/backfill/sink/create_sink.slt +++ b/e2e_test/backfill/sink/create_sink.slt @@ -7,9 +7,9 @@ create table t (v1 int); statement ok SET STREAMING_RATE_LIMIT = 1000; -# Should finish in 10s +# Should finish in 20s statement ok -insert into t select * from generate_series(1, 10000); +insert into t select * from generate_series(1, 20000); statement ok SET BACKGROUND_DDL=true;