fix(test): fix recovery test case (#16245)

Signed-off-by: Runji Wang <[email protected]>
risingwavelabs · Apr 11, 2024 · a4a944d · a4a944d
1 parent 132b4c9
commit a4a944d
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/e2e_test/streaming/nexmark_snapshot.slt b/e2e_test/streaming/nexmark_snapshot.slt
@@ -5,6 +5,10 @@ include ../nexmark/insert_person.slt.part
 include ../nexmark/insert_auction.slt.part
 include ../nexmark/insert_bid.slt.part
 
+# Ensure that the upstream data is fully consumed
+statement ok
+flush;
+
 # Then, create materialized views based on the historical data (snapshot)
 include ./nexmark/create_views.slt.part