diff --git a/src/frontend/src/handler/create_table_as.rs b/src/frontend/src/handler/create_table_as.rs
index ceb6837c27d56..e84effa9a5d2e 100644
--- a/src/frontend/src/handler/create_table_as.rs
+++ b/src/frontend/src/handler/create_table_as.rs
@@ -108,7 +108,7 @@ pub async fn handle_create_as(
             append_only,
             Some(col_id_gen.into_version()),
         )?;
-        let mut graph: risingwave_pb::stream_plan::StreamFragmentGraph = build_graph(plan);
+        let mut graph = build_graph(plan);
         graph.parallelism = session
             .config()
             .get_streaming_parallelism()