test: workaround a flaky source test (#19729)

Signed-off-by: xxchan <[email protected]>
risingwavelabs · Dec 10, 2024 · 00ee666 · 00ee666
1 parent c269f84
commit 00ee666
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/e2e_test/source_inline/kafka/issue_19563.slt.serial b/e2e_test/source_inline/kafka/issue_19563.slt.serial
@@ -46,6 +46,10 @@ select array_length(upstream_fragment_ids) from rw_fragments where array_contain
 ----
 3
 
+# XXX: wait until source reader is ready. then produce data.
+# This is a temporary workaround for a data loss bug https://github.com/risingwavelabs/risingwave/issues/19681#issuecomment-2532183002
+sleep 2s
+
 system ok
 cat <<EOF | rpk topic produce test-topic-19563
 {"v1": "3031-01-01 19:00:00"}
@@ -70,4 +74,4 @@ statement ok
 DROP SOURCE kafkasource CASCADE;
 
 system ok
-rpk topic delete test-topic-18308
+rpk topic delete test-topic-19563