diff --git a/src/datanode/src/region_server.rs b/src/datanode/src/region_server.rs
index 8625de02b3..433666be34 100644
--- a/src/datanode/src/region_server.rs
+++ b/src/datanode/src/region_server.rs
@@ -936,11 +936,10 @@ impl RegionServerInner {
         }
 
         for (_, (engine, request)) in engine_requests {
-            // TODO(yingwen): Error for batch request.
             engine
                 .handle_batch_request(BatchRegionRequest::Put(request))
                 .await
-                .unwrap();
+                .context(HandleBatchRequestSnafu)?;
         }
 
         // match engine