fix(test): fix some flaky e2e source tests (#18989)

Signed-off-by: xxchan <[email protected]>
risingwavelabs · Oct 18, 2024 · 71f19f3 · 71f19f3
1 parent 55dc238
commit 71f19f3
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/e2e_test/source_inline/kafka/avro/glue.slt b/e2e_test/source_inline/kafka/avro/glue.slt
@@ -14,6 +14,8 @@ EOF
 statement ok
 ALTER SYSTEM SET license_key TO '';
 
+sleep 1s
+
 statement error
 create source t with (
   connector = 'kafka',

diff --git a/e2e_test/source_inline/kafka/temporary_kafka_batch.slt b/e2e_test/source_inline/kafka/temporary_kafka_batch.slt
@@ -71,6 +71,12 @@ t
 t
 t
 
+# ensure now() is larger
+sleep 1s
+
+statement ok
+flush;
+
 query B
 select _rw_kafka_timestamp < now() from s1
 ----