diff --git a/src/handler/grpc/request/query_cache.rs b/src/handler/grpc/request/query_cache.rs
index 49425806e9..8a2b53ea5b 100644
--- a/src/handler/grpc/request/query_cache.rs
+++ b/src/handler/grpc/request/query_cache.rs
@@ -30,12 +30,9 @@ impl QueryCache for QueryCacheServerImpl {
         request: Request<DeleteResultCacheRequest>,
     ) -> Result<Response<DeleteResultCacheResponse>, Status> {
         let req: DeleteResultCacheRequest = request.into_inner();
-        let deleted = cacher::delete_cache(
-            &req.path, req.ts, None, // TODO: fix proper param
-            None, // TODO: fix proper param
-        )
-        .await
-        .is_ok();
+        let deleted = cacher::delete_cache(&req.path, req.ts, None, None)
+            .await
+            .is_ok();
 
         Ok(Response::new(DeleteResultCacheResponse { deleted }))
     }
diff --git a/src/service/search/cluster/flight.rs b/src/service/search/cluster/flight.rs
index 90759dda5f..8dee603fc3 100644
--- a/src/service/search/cluster/flight.rs
+++ b/src/service/search/cluster/flight.rs
@@ -456,9 +456,8 @@ pub async fn run_datafusion(
                     .build()
             )
         );
-        let mut scan_stats = visit.scan_stats;
         // Update scan stats to include aggregation cache ratio
-        scan_stats.aggs_cache_ratio = aggs_cache_ratio;
+        visit.scan_stats.aggs_cache_ratio = aggs_cache_ratio;
         ret.map(|data| {
             check_query_default_limit_exceeded(
                 data.iter().fold(0, |acc, batch| acc + batch.num_rows()),