diff --git a/e2e_test/streaming/now.slt b/e2e_test/streaming/now.slt
index 324469e947e7a..ad086f2202e7a 100644
--- a/e2e_test/streaming/now.slt
+++ b/e2e_test/streaming/now.slt
@@ -2,6 +2,8 @@
 skipif madsim
 # In parallel test, we cannot get the DB name.
 skipif parallel
+# TODO: Later if we introduce a new `now()`-like function that returns the time of statement execution,
+# we'll be able to directly create MV without `./risedev psql` and so that we can remove these `skipif`.
 system ok
 ./risedev psql -c "
 create materialized view mv as
@@ -20,7 +22,7 @@ flush;
 skipif madsim
 skipif parallel
 query I
-select count(*) > 10 from mv;
+select count(*) >= 10 from mv;
 ----
 t
 
@@ -28,10 +30,15 @@ skipif madsim
 skipif parallel
 sleep 2s
 
+skipif madsim
+skipif parallel
+statement ok
+flush;
+
 skipif madsim
 skipif parallel
 query I
-select count(*) > 12 from mv;
+select count(*) >= 12 from mv;
 ----
 t