clear tracker early

risingwavelabs · Aug 7, 2024 · 9f0b27a · 9f0b27a
1 parent 9474aa1
commit 9f0b27a
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/src/meta/src/manager/catalog/mod.rs b/src/meta/src/manager/catalog/mod.rs
@@ -249,6 +249,9 @@ impl CatalogManagerCore {
         {
             let _ = tx.send(Err(err.clone()));
         }
+        // Clear in progress creation streaming job. Note that background job is not tracked here, so that
+        // it won't affect background jobs.
+        self.database.in_progress_creation_streaming_job.clear();
     }
 }
 

diff --git a/src/tests/simulation/tests/integration_tests/recovery/background_ddl.rs b/src/tests/simulation/tests/integration_tests/recovery/background_ddl.rs
@@ -262,12 +262,12 @@ async fn test_high_barrier_latency_cancel(config: Configuration) -> Result<()> {
 
     session.run("CREATE TABLE fact1 (v1 int)").await?;
     session
-        .run("INSERT INTO fact1 select 1 from generate_series(1, 100000)")
+        .run("INSERT INTO fact1 select 1 from generate_series(1, 10000)")
         .await?;
 
     session.run("CREATE TABLE fact2 (v1 int)").await?;
     session
-        .run("INSERT INTO fact2 select 1 from generate_series(1, 100000)")
+        .run("INSERT INTO fact2 select 1 from generate_series(1, 10000)")
         .await?;
     session.flush().await?;