fix

BugenZhao · BugenZhao · commit 24c0bd14f5d3 · 2023-09-01T17:03:27.000+08:00
Signed-off-by: Bugen Zhao &lt;i@bugenzhao.com&gt;
diff --git a/src/tests/simulation/tests/integration_tests/recovery/pause_on_bootstrap.rs b/src/tests/simulation/tests/integration_tests/recovery/pause_on_bootstrap.rs
@@ -77,7 +77,7 @@ async fn test_impl(resume_by: ResumeBy) -> Result<()> {
         let mut session = cluster.start_session();
         session.run(INSERT_INTO_TABLE).await?;
         session.run("FLUSH").await?;
-        cluster.run(SELECT_COUNT_TABLE).await?.assert_result_eq("1");
+        session.run(SELECT_COUNT_TABLE).await?.assert_result_eq("1");
     }
 
     Ok(())

Original file line number	Diff line number	Diff line change
`@@ -77,7 +77,7 @@ async fn test_impl(resume_by: ResumeBy) -> Result<()> {`
`77`	`77`	`let mut session = cluster.start_session();`
`78`	`78`	`session.run(INSERT_INTO_TABLE).await?;`
`79`	`79`	`session.run("FLUSH").await?;`
`80`		`- cluster.run(SELECT_COUNT_TABLE).await?.assert_result_eq("1");`
	`80`	`+ session.run(SELECT_COUNT_TABLE).await?.assert_result_eq("1");`
`81`	`81`	`}`
`82`	`82`
`83`	`83`	`Ok(())`