diff --git a/src/meta/src/controller/catalog.rs b/src/meta/src/controller/catalog.rs index fe3f4ced3ab21..227807b679d94 100644 --- a/src/meta/src/controller/catalog.rs +++ b/src/meta/src/controller/catalog.rs @@ -3525,6 +3525,8 @@ async fn update_internal_tables( #[cfg(test)] mod tests { + use risingwave_pb::catalog::StreamSourceInfo; + use super::*; const TEST_DATABASE_ID: DatabaseId = 1; @@ -3684,6 +3686,9 @@ mod tests { scan.startup.mode = 'earliest' ) FORMAT PLAIN ENCODE JSON"# .to_string(), + info: Some(StreamSourceInfo { + ..Default::default() + }), ..Default::default() }; mgr.create_source(pb_source).await?;