diff --git a/e2e_test/sink/pulsar_sink.slt b/e2e_test/sink/pulsar_sink.slt index 73c0220ce0f5e..a3c52d5712537 100644 --- a/e2e_test/sink/pulsar_sink.slt +++ b/e2e_test/sink/pulsar_sink.slt @@ -39,6 +39,10 @@ WITH ( statement ok FLUSH; +# We can't control Sink -> Source Table +# latency. We just have to wait. +sleep 5 + query IT rowsort SELECT * FROM pulsar_source; ----