diff --git a/e2e_test/source_inline/kafka/avro/glue.slt b/e2e_test/source_inline/kafka/avro/glue.slt
index 4be9378b530d..70d9c1d80024 100644
--- 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
index 69144a884486..47c6124e595d 100644
--- 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
 ----