fix clippy

Signed-off-by: Bugen Zhao <[email protected]>
risingwavelabs · Apr 1, 2024 · 726c6f6 · 726c6f6
1 parent 1fe1346
commit 726c6f6
Showing 1 changed file with 1 addition and 3 deletions.
diff --git 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();