From a1344f039e069607d229e6e3cb92e8599c954af8 Mon Sep 17 00:00:00 2001 From: xxchan Date: Fri, 18 Oct 2024 10:58:14 +0800 Subject: [PATCH 1/2] fix(test): fix flaky temporary_kafka_batch.slt Signed-off-by: xxchan --- e2e_test/source_inline/kafka/temporary_kafka_batch.slt | 6 ++++++ 1 file changed, 6 insertions(+) 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 ---- From 743f9bba559b6127e0a6430294ceff1bc8110c28 Mon Sep 17 00:00:00 2001 From: xxchan Date: Fri, 18 Oct 2024 15:08:18 +0800 Subject: [PATCH 2/2] fix license Signed-off-by: xxchan --- e2e_test/source_inline/kafka/avro/glue.slt | 2 ++ 1 file changed, 2 insertions(+) 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',