diff --git a/src/server.rs b/src/server.rs
index f48df77e..14221976 100644
--- a/src/server.rs
+++ b/src/server.rs
@@ -63,7 +63,7 @@ pub async fn init_server(
                 )
                 .route(
                     "/flows/:flowInstName/rowStatus",
-                    routing::get(service::flows::get_row_index_status),
+                    routing::get(service::flows::get_row_indexing_status),
                 )
                 .route(
                     "/flows/:flowInstName/update",
diff --git a/src/service/flows.rs b/src/service/flows.rs
index 07c43dfe..f0d243ff 100644
--- a/src/service/flows.rs
+++ b/src/service/flows.rs
@@ -209,17 +209,17 @@ pub async fn update(
     Ok(Json(live_updater.index_update_info()))
 }
 
-pub async fn get_row_index_status(
+pub async fn get_row_indexing_status(
     Path(flow_name): Path<String>,
     Query(query): Query<SourceRowKeyParams>,
     State(lib_context): State<Arc<LibContext>>,
 ) -> Result<Json<indexing_status::SourceRowIndexingStatus>, ApiError> {
     let flow_ctx = lib_context.get_flow_context(&flow_name)?;
     let source_row_key_ctx = SourceRowKeyContextHolder::create(&flow_ctx, query).await?;
-    let index_status = indexing_status::get_source_row_indexing_status(
+    let indexing_status = indexing_status::get_source_row_indexing_status(
         &source_row_key_ctx.as_context(),
         &lib_context.builtin_db_pool,
     )
     .await?;
-    Ok(Json(index_status))
+    Ok(Json(indexing_status))
 }