simplify background_ddl test

risingwavelabs · Nov 2, 2023 · bd82f41 · bd82f41
1 parent e12dcd9
commit bd82f41
Showing 1 changed file with 6 additions and 5 deletions.
diff --git a/src/tests/simulation/tests/integration_tests/recovery/background_ddl.rs b/src/tests/simulation/tests/integration_tests/recovery/background_ddl.rs
@@ -108,15 +108,13 @@ async fn test_background_mv_barrier_recovery() -> Result<()> {
 
     // Send some upstream updates.
     session.run(SEED_TABLE).await?;
-    session.run(SEED_TABLE).await?;
     session.flush().await?;
 
     kill_and_wait_recover(&cluster).await;
     kill_cn_and_wait_recover(&cluster).await;
 
     // Send some upstream updates.
     session.run(SEED_TABLE).await?;
-    session.run(SEED_TABLE).await?;
     session.flush().await?;
 
     kill_cn_and_wait_recover(&cluster).await;
@@ -125,10 +123,13 @@ async fn test_background_mv_barrier_recovery() -> Result<()> {
     // Now just wait for it to complete.
     session.run(WAIT).await?;
 
-    session
+    let t_count = session.run("SELECT COUNT(v1) FROM t").await?;
+
+    let mv1_count = session
         .run("SELECT COUNT(v1) FROM mv1")
-        .await?
-        .assert_result_eq("3500");
+        .await?;
+
+    assert_eq!(t_count, mv1_count);
 
     // Make sure that if MV killed and restarted
     // it will not be dropped.