From fae410f4a0f5371f391e03b278680c358a5ad2b3 Mon Sep 17 00:00:00 2001
From: discord9 <discord9@163.com>
Date: Tue, 14 May 2024 11:44:38 +0800
Subject: [PATCH] chore: typos

---
 src/flow/src/adapter.rs              | 2 +-
 src/flow/src/adapter/node_context.rs | 8 ++++----
 src/flow/src/adapter/util.rs         | 2 +-
 3 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/src/flow/src/adapter.rs b/src/flow/src/adapter.rs
index e7061bc93d63..b36442a57dd5 100644
--- a/src/flow/src/adapter.rs
+++ b/src/flow/src/adapter.rs
@@ -233,7 +233,7 @@ impl FlownodeManager {
         (zelf, worker)
     }
 
-    /// add a worker handler to manager, meaning this corrseponding worker is under it's manage
+    /// add a worker handler to manager, meaning this corresponding worker is under it's manage
     pub fn add_worker_handle(&mut self, handle: WorkerHandle) {
         self.worker_handles.push(Mutex::new(handle));
     }
diff --git a/src/flow/src/adapter/node_context.rs b/src/flow/src/adapter/node_context.rs
index 3a40e92691f5..0b69e01855f2 100644
--- a/src/flow/src/adapter/node_context.rs
+++ b/src/flow/src/adapter/node_context.rs
@@ -117,7 +117,7 @@ impl SourceSender {
         Ok(row_cnt)
     }
 
-    /// return number of rows it actuall send(including what's in the buffer)
+    /// return number of rows it actual send(including what's in the buffer)
     pub fn send_rows(&mut self, rows: Vec<DiffRow>) -> Result<usize, Error> {
         self.send_buf.extend(rows);
 
@@ -128,7 +128,7 @@ impl SourceSender {
 }
 
 impl FlownodeContext {
-    /// return number of rows it actuall send(including what's in the buffer)
+    /// return number of rows it actual send(including what's in the buffer)
     ///
     /// TODO(discord9): make this concurrent
     pub fn send(&mut self, table_id: TableId, rows: Vec<DiffRow>) -> Result<usize, Error> {
@@ -154,7 +154,7 @@ impl FlownodeContext {
 impl FlownodeContext {
     /// mapping source table to task, and sink table to task in worker context
     ///
-    /// also add their corrseponding broadcast sender/receiver
+    /// also add their corresponding broadcast sender/receiver
     pub fn register_task_src_sink(
         &mut self,
         task_id: FlowId,
@@ -253,7 +253,7 @@ impl FlownodeContext {
     ///
     /// and will try to fetch the schema from table info manager(if table exist now)
     ///
-    /// NOTE: this will not actually render the table into collection refered as GlobalId
+    /// NOTE: this will not actually render the table into collection referred as GlobalId
     /// merely creating a mapping from table id to global id
     pub async fn assign_global_id_to_table(
         &mut self,
diff --git a/src/flow/src/adapter/util.rs b/src/flow/src/adapter/util.rs
index 66d8e946f3db..235917ac8724 100644
--- a/src/flow/src/adapter/util.rs
+++ b/src/flow/src/adapter/util.rs
@@ -21,7 +21,7 @@ use snafu::ResultExt;
 
 use crate::adapter::error::{Error, ExternalSnafu};
 
-/// convert `ColumnSchema` lists to it's corrsponding proto type
+/// convert `ColumnSchema` lists to it's corresponding proto type
 pub fn column_schemas_to_proto(
     column_schemas: Vec<ColumnSchema>,
     primary_keys: &[String],