diff --git a/src/batch/src/executor/mod.rs b/src/batch/src/executor/mod.rs
index 4e8d2138549e..3b0298643484 100644
--- a/src/batch/src/executor/mod.rs
+++ b/src/batch/src/executor/mod.rs
@@ -78,7 +78,7 @@ pub use update::*;
 pub use utils::*;
 pub use values::*;
 
-use self::test_utils::{BlockExecutorBuidler, BusyLoopExecutorBuidler};
+use self::test_utils::{BlockExecutorBuilder, BusyLoopExecutorBuilder};
 use crate::error::Result;
 use crate::executor::sys_row_seq_scan::SysRowSeqScanExecutorBuilder;
 use crate::task::{BatchTaskContext, ShutdownToken, TaskId};
@@ -235,8 +235,8 @@ impl<'a, C: BatchTaskContext> ExecutorBuilder<'a, C> {
             NodeBody::SortOverWindow => SortOverWindowExecutor,
             NodeBody::MaxOneRow => MaxOneRowExecutor,
             // Follow NodeBody only used for test
-            NodeBody::BlockExecutor => BlockExecutorBuidler,
-            NodeBody::BusyLoopExecutor => BusyLoopExecutorBuidler,
+            NodeBody::BlockExecutor => BlockExecutorBuilder,
+            NodeBody::BusyLoopExecutor => BusyLoopExecutorBuilder,
         }
         .await?;
 
diff --git a/src/batch/src/executor/test_utils.rs b/src/batch/src/executor/test_utils.rs
index 0bb998b1b99e..41444d149887 100644
--- a/src/batch/src/executor/test_utils.rs
+++ b/src/batch/src/executor/test_utils.rs
@@ -337,10 +337,10 @@ impl LookupExecutorBuilder for FakeInnerSideExecutorBuilder {
     }
 }
 
-pub struct BlockExecutorBuidler {}
+pub struct BlockExecutorBuilder {}
 
 #[async_trait::async_trait]
-impl BoxedExecutorBuilder for BlockExecutorBuidler {
+impl BoxedExecutorBuilder for BlockExecutorBuilder {
     async fn new_boxed_executor<C: BatchTaskContext>(
         _source: &ExecutorBuilder<'_, C>,
         _inputs: Vec<BoxedExecutor>,
@@ -374,10 +374,10 @@ impl BlockExecutor {
     }
 }
 
-pub struct BusyLoopExecutorBuidler {}
+pub struct BusyLoopExecutorBuilder {}
 
 #[async_trait::async_trait]
-impl BoxedExecutorBuilder for BusyLoopExecutorBuidler {
+impl BoxedExecutorBuilder for BusyLoopExecutorBuilder {
     async fn new_boxed_executor<C: BatchTaskContext>(
         _source: &ExecutorBuilder<'_, C>,
         _inputs: Vec<BoxedExecutor>,
diff --git a/src/batch/src/executor/update.rs b/src/batch/src/executor/update.rs
index 5717abacc0de..e75fca228e1e 100644
--- a/src/batch/src/executor/update.rs
+++ b/src/batch/src/executor/update.rs
@@ -32,7 +32,7 @@ use crate::executor::{
 };
 use crate::task::BatchTaskContext;
 
-/// [`UpdateExecutor`] implements table updation with values from its child executor and given
+/// [`UpdateExecutor`] implements table update with values from its child executor and given
 /// expressions.
 // Note: multiple `UPDATE`s in a single epoch, or concurrent `UPDATE`s may lead to conflicting
 // records. This is validated and filtered on the first `Materialize`.
diff --git a/src/common/proc_macro/src/lib.rs b/src/common/proc_macro/src/lib.rs
index 61f7573a0b73..77807f8291ff 100644
--- a/src/common/proc_macro/src/lib.rs
+++ b/src/common/proc_macro/src/lib.rs
@@ -72,7 +72,7 @@ pub fn derive_estimate_size(input: TokenStream) -> TokenStream {
     // that we can manipulate
     let ast: syn::DeriveInput = syn::parse(input).unwrap();
 
-    // The name of the sruct.
+    // The name of the struct.
     let name = &ast.ident;
 
     // Extract all generics we shall ignore.
diff --git a/src/connector/src/sink/doris.rs b/src/connector/src/sink/doris.rs
index a14bc99b9e20..dbe87b4cb51c 100644
--- a/src/connector/src/sink/doris.rs
+++ b/src/connector/src/sink/doris.rs
@@ -229,7 +229,7 @@ pub struct DorisSinkWriter {
     pub config: DorisConfig,
     schema: Schema,
     pk_indices: Vec<usize>,
-    inseter_inner_builder: InserterInnerBuilder,
+    inserter_inner_builder: InserterInnerBuilder,
     is_append_only: bool,
     client: Option<DorisClient>,
     row_encoder: JsonEncoder,
@@ -290,7 +290,7 @@ impl DorisSinkWriter {
             config,
             schema: schema.clone(),
             pk_indices,
-            inseter_inner_builder: doris_insert_builder,
+            inserter_inner_builder: doris_insert_builder,
             is_append_only,
             client: None,
             row_encoder: JsonEncoder::new_with_doris(
@@ -379,7 +379,7 @@ impl DorisSinkWriter {
 impl SinkWriter for DorisSinkWriter {
     async fn write_batch(&mut self, chunk: StreamChunk) -> Result<()> {
         if self.client.is_none() {
-            self.client = Some(DorisClient::new(self.inseter_inner_builder.build().await?));
+            self.client = Some(DorisClient::new(self.inserter_inner_builder.build().await?));
         }
         if self.is_append_only {
             self.append_only(chunk).await
diff --git a/src/meta/src/stream/scale.rs b/src/meta/src/stream/scale.rs
index d4792c0ba8e2..376d8ad69e59 100644
--- a/src/meta/src/stream/scale.rs
+++ b/src/meta/src/stream/scale.rs
@@ -1654,7 +1654,7 @@ impl ScaleController {
 
         for worker_id in &worker_ids {
             if unschedulable_worker_ids.contains(worker_id) {
-                bail!("Cannot include unscheduable worker {}", worker_id)
+                bail!("Cannot include unschedulable worker {}", worker_id)
             }
         }
 
diff --git a/src/storage/src/hummock/sstable/block.rs b/src/storage/src/hummock/sstable/block.rs
index bc038acbce7c..d21869f8ba09 100644
--- a/src/storage/src/hummock/sstable/block.rs
+++ b/src/storage/src/hummock/sstable/block.rs
@@ -133,7 +133,7 @@ pub struct RestartPoint {
 
 impl RestartPoint {
     fn size_of() -> usize {
-        // store key_len_type and value_len_type in u8 related to `BlockBuidler::build`
+        // store key_len_type and value_len_type in u8 related to `BlockBuilder::build`
         // encoding_value = (key_len_type << 4) | value_len_type
         std::mem::size_of::<u32>() + std::mem::size_of::<LenType>()
     }