diff --git a/src/meta/src/controller/fragment.rs b/src/meta/src/controller/fragment.rs index d8e4d546ec90..3adfacb16be0 100644 --- a/src/meta/src/controller/fragment.rs +++ b/src/meta/src/controller/fragment.rs @@ -1297,6 +1297,7 @@ impl CatalogController { .await?; } } + txn.commit().await?; Ok(()) }