From f336df756d512180f7984fa53516d6ade879492d Mon Sep 17 00:00:00 2001 From: August Date: Wed, 7 Feb 2024 14:14:48 +0800 Subject: [PATCH] remove debug logs --- src/meta/src/controller/streaming_job.rs | 14 -------------- 1 file changed, 14 deletions(-) diff --git a/src/meta/src/controller/streaming_job.rs b/src/meta/src/controller/streaming_job.rs index 8ed85cc5147c..f4004e25b500 100644 --- a/src/meta/src/controller/streaming_job.rs +++ b/src/meta/src/controller/streaming_job.rs @@ -305,25 +305,11 @@ impl CatalogController { .map(|(fragment, actors, actor_dispatchers)| (fragment, (actors, actor_dispatchers))) .unzip(); for fragment in fragments { - // let x = serde_json::to_value(&fragment.stream_node).unwrap(); - // let y: StreamNode = serde_json::from_value(x).unwrap(); - // println!("heiheihei: {:?}", y); - let fragment_id = fragment.fragment_id; let state_table_ids = fragment.state_table_ids.inner_ref().clone(); let fragment = fragment.into_active_model(); - Fragment::insert(fragment).exec(&txn).await?; - // PANIC: stack overflow. - // let stream_node: StreamNode = Fragment::find_by_id(fragment_id) - // .select_only() - // .column(fragment::Column::StreamNode) - // .into_tuple() - // .one(&txn) - // .await? - // .unwrap(); - // Update fragment id for all state tables. if !for_replace { for state_table_id in state_table_ids {