remove debug logs

risingwavelabs · Feb 7, 2024 · f336df7 · f336df7
1 parent 2e77a0c
commit f336df7
Showing 1 changed file with 0 additions and 14 deletions.
diff --git 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 {