diff --git a/src/meta/src/controller/fragment.rs b/src/meta/src/controller/fragment.rs index 0593c2b754f8b..40fdbac5eb21c 100644 --- a/src/meta/src/controller/fragment.rs +++ b/src/meta/src/controller/fragment.rs @@ -718,7 +718,10 @@ impl CatalogController { Expr::col((table::Entity, table::Column::Name)), Expr::if_null( Expr::col((source::Entity, source::Column::Name)), - Expr::col((sink::Entity, sink::Column::Name)), + Expr::if_null( + Expr::col((sink::Entity, sink::Column::Name)), + Expr::val(""), + ), ), ), "name",