diff --git a/ci/scripts/run-backfill-tests.sh b/ci/scripts/run-backfill-tests.sh index ac552cfcdcdd0..c03762a7150a7 100755 --- a/ci/scripts/run-backfill-tests.sh +++ b/ci/scripts/run-backfill-tests.sh @@ -185,6 +185,9 @@ 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 5 + # Restart restart_cluster sleep 5 diff --git a/e2e_test/backfill/sink/create_sink.slt b/e2e_test/backfill/sink/create_sink.slt index 017eb8e693de2..016e3bcb2049b 100644 --- a/e2e_test/backfill/sink/create_sink.slt +++ b/e2e_test/backfill/sink/create_sink.slt @@ -5,9 +5,9 @@ statement ok create table t (v1 int); statement ok -SET STREAMING_RATE_LIMIT = 1000; +SET STREAMING_RATE_LIMIT = 500; -# Should finish in 10s +# Should finish in 20s statement ok insert into t select * from generate_series(1, 10000);