From 4b482535776c803b4e2d1c448546b9a8ae4b580d Mon Sep 17 00:00:00 2001 From: tabversion Date: Tue, 5 Nov 2024 15:41:11 +0800 Subject: [PATCH] fix --- src/meta/src/controller/catalog.rs | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/src/meta/src/controller/catalog.rs b/src/meta/src/controller/catalog.rs index fe3f4ced3ab2..227807b679d9 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?;