fix

risingwavelabs · Jun 21, 2024 · 3f0589b · 3f0589b
1 parent 67be142
commit 3f0589b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/meta/src/stream/stream_manager.rs b/src/meta/src/stream/stream_manager.rs
@@ -1213,7 +1213,7 @@ mod tests {
                 source_manager.clone(),
                 stream_rpc_manager,
                 scale_controller.clone(),
-            ))?;
+            )?);
 
             let barrier_manager = GlobalBarrierManager::new(
                 scheduled_barriers,