diff --git a/src/batch/src/executor/mod.rs b/src/batch/src/executor/mod.rs
index 35394d01831a9..da35ad8e9d4a6 100644
--- a/src/batch/src/executor/mod.rs
+++ b/src/batch/src/executor/mod.rs
@@ -229,7 +229,7 @@ impl<'a, C: BatchTaskContext> ExecutorBuilder<'a, C> {
 
 #[cfg(test)]
 mod tests {
-    use risingwave_hummock_sdk::to_commited_batch_query_epoch;
+    use risingwave_hummock_sdk::to_committed_batch_query_epoch;
     use risingwave_pb::batch_plan::PlanNode;
 
     use crate::executor::ExecutorBuilder;
@@ -249,7 +249,7 @@ mod tests {
             &plan_node,
             task_id,
             ComputeNodeContext::for_test(),
-            to_commited_batch_query_epoch(u64::MAX),
+            to_committed_batch_query_epoch(u64::MAX),
         );
         let child_plan = &PlanNode {
             ..Default::default()
diff --git a/src/batch/src/task/task_manager.rs b/src/batch/src/task/task_manager.rs
index 8a19023e53764..b10a15a286daf 100644
--- a/src/batch/src/task/task_manager.rs
+++ b/src/batch/src/task/task_manager.rs
@@ -215,7 +215,7 @@ mod tests {
     use risingwave_common::config::BatchConfig;
     use risingwave_common::types::DataType;
     use risingwave_expr::expr::make_i32_literal;
-    use risingwave_hummock_sdk::to_commited_batch_query_epoch;
+    use risingwave_hummock_sdk::to_committed_batch_query_epoch;
     use risingwave_pb::batch_plan::exchange_info::DistributionMode;
     use risingwave_pb::batch_plan::plan_node::NodeBody;
     use risingwave_pb::batch_plan::{
@@ -284,13 +284,13 @@ mod tests {
             .fire_task(
                 &task_id,
                 plan.clone(),
-                to_commited_batch_query_epoch(0),
+                to_committed_batch_query_epoch(0),
                 context.clone(),
             )
             .await
             .unwrap();
         let err = manager
-            .fire_task(&task_id, plan, to_commited_batch_query_epoch(0), context)
+            .fire_task(&task_id, plan, to_committed_batch_query_epoch(0), context)
             .await
             .unwrap_err();
         assert!(err
@@ -334,7 +334,7 @@ mod tests {
             .fire_task(
                 &task_id,
                 plan.clone(),
-                to_commited_batch_query_epoch(0),
+                to_committed_batch_query_epoch(0),
                 context.clone(),
             )
             .await
diff --git a/src/compute/tests/integration_tests.rs b/src/compute/tests/integration_tests.rs
index 9eb196a792cf7..ce86a6c981005 100644
--- a/src/compute/tests/integration_tests.rs
+++ b/src/compute/tests/integration_tests.rs
@@ -35,7 +35,7 @@ use risingwave_common::test_prelude::DataChunkTestExt;
 use risingwave_common::types::{DataType, IntoOrdered};
 use risingwave_common::util::epoch::EpochPair;
 use risingwave_common::util::sort_util::{OrderPair, OrderType};
-use risingwave_hummock_sdk::to_commited_batch_query_epoch;
+use risingwave_hummock_sdk::to_committed_batch_query_epoch;
 use risingwave_source::table_test_utils::create_table_source_desc_builder;
 use risingwave_source::{TableSourceManager, TableSourceManagerRef};
 use risingwave_storage::memory::MemoryStateStore;
@@ -221,7 +221,7 @@ async fn test_table_materialize() -> StreamResult<()> {
     let scan = Box::new(RowSeqScanExecutor::new(
         table.clone(),
         vec![ScanRange::full()],
-        to_commited_batch_query_epoch(u64::MAX),
+        to_committed_batch_query_epoch(u64::MAX),
         1024,
         "RowSeqExecutor2".to_string(),
         None,
@@ -283,7 +283,7 @@ async fn test_table_materialize() -> StreamResult<()> {
     let scan = Box::new(RowSeqScanExecutor::new(
         table.clone(),
         vec![ScanRange::full()],
-        to_commited_batch_query_epoch(u64::MAX),
+        to_committed_batch_query_epoch(u64::MAX),
         1024,
         "RowSeqScanExecutor2".to_string(),
         None,
@@ -355,7 +355,7 @@ async fn test_table_materialize() -> StreamResult<()> {
     let scan = Box::new(RowSeqScanExecutor::new(
         table,
         vec![ScanRange::full()],
-        to_commited_batch_query_epoch(u64::MAX),
+        to_committed_batch_query_epoch(u64::MAX),
         1024,
         "RowSeqScanExecutor2".to_string(),
         None,
@@ -422,7 +422,7 @@ async fn test_row_seq_scan() -> Result<()> {
     let executor = Box::new(RowSeqScanExecutor::new(
         table,
         vec![ScanRange::full()],
-        to_commited_batch_query_epoch(u64::MAX),
+        to_committed_batch_query_epoch(u64::MAX),
         1,
         "RowSeqScanExecutor2".to_string(),
         None,
diff --git a/src/storage/hummock_sdk/src/lib.rs b/src/storage/hummock_sdk/src/lib.rs
index 0a6a9cdafd167..0ffaf679821e0 100644
--- a/src/storage/hummock_sdk/src/lib.rs
+++ b/src/storage/hummock_sdk/src/lib.rs
@@ -183,7 +183,7 @@ impl From<BatchQueryEpoch> for HummockReadEpoch {
     }
 }
 
-pub fn to_commited_batch_query_epoch(epoch: u64) -> BatchQueryEpoch {
+pub fn to_committed_batch_query_epoch(epoch: u64) -> BatchQueryEpoch {
     BatchQueryEpoch {
         epoch: Some(batch_query_epoch::Epoch::Committed(epoch)),
     }