diff --git a/src/flow/src/adapter.rs b/src/flow/src/adapter.rs
index 4bfb0d8b17..f29d5333f4 100644
--- a/src/flow/src/adapter.rs
+++ b/src/flow/src/adapter.rs
@@ -532,7 +532,6 @@ pub struct FlowNodeContext {
 }
 
 impl FlowNodeContext {
-    // TODO(discord9): add send_buf in case the broadcast channel is full
     // return number of rows it actuall send(including what's in the buffer)
     pub fn send(&mut self, table_id: TableId, rows: Vec<DiffRow>) -> Result<usize, Error> {
         let sender = self
diff --git a/src/flow/src/adapter/worker.rs b/src/flow/src/adapter/worker.rs
index 9aa238e2a1..ae22fdb5f2 100644
--- a/src/flow/src/adapter/worker.rs
+++ b/src/flow/src/adapter/worker.rs
@@ -161,9 +161,7 @@ impl WorkerHandle {
             Ok(result)
         } else {
             InternalSnafu {
-                reason: format!(
-                    "Flow Node/Worker itc failed, expect Response::Remove, found {ret:?}"
-                ),
+                reason: format!("Flow Node/Worker failed, expect Response::Remove, found {ret:?}"),
             }
             .fail()
             .with_context(|_| EvalSnafu {})