From 726c6f6b12a9153607db8bfc0df39906ca86cda0 Mon Sep 17 00:00:00 2001
From: Bugen Zhao <i@bugenzhao.com>
Date: Mon, 1 Apr 2024 15:22:37 +0800
Subject: [PATCH] fix clippy

Signed-off-by: Bugen Zhao <i@bugenzhao.com>
---
 src/stream/src/task/stream_manager.rs | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

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();