diff --git a/src/stream/src/task/stream_manager.rs b/src/stream/src/task/stream_manager.rs
index c079bbe26e486..0c946ae36c853 100644
--- a/src/stream/src/task/stream_manager.rs
+++ b/src/stream/src/task/stream_manager.rs
@@ -171,9 +171,7 @@ impl LocalStreamManager {
         await_tree_config: Option<await_tree::Config>,
         watermark_epoch: AtomicU64Ref,
     ) -> Self {
-        let await_tree_reg = await_tree_config
-            .clone()
-            .map(|config| await_tree::Registry::new(config));
+        let await_tree_reg = await_tree_config.clone().map(await_tree::Registry::new);
 
         let (actor_op_tx, actor_op_rx) = unbounded_channel();