diff --git a/src/meta/src/manager/catalog/user.rs b/src/meta/src/manager/catalog/user.rs index 0da37291a1634..f4f407c513724 100644 --- a/src/meta/src/manager/catalog/user.rs +++ b/src/meta/src/manager/catalog/user.rs @@ -67,6 +67,13 @@ impl UserManager { .map(|table| table.owner), ) .chain(database.views.values().map(|view| view.owner)) + .chain(database.functions.values().map(|function| function.owner)) + .chain( + database + .connections + .values() + .map(|connection| connection.owner), + ) .for_each(|owner_id| user_manager.increase_ref(owner_id)); Ok(user_manager)