From c7ee02a9f1c4e0fde3fc2d818b1ce2babc14dbb2 Mon Sep 17 00:00:00 2001 From: Loakesh Indiran <66478092+Loaki07@users.noreply.github.com> Date: Thu, 6 Nov 2025 22:07:59 +0530 Subject: [PATCH] fix: aggs cache ratio reporting (#8984) Signed-off-by: loaki07 --- src/handler/grpc/request/query_cache.rs | 9 +++------ src/service/search/cluster/flight.rs | 3 +-- 2 files changed, 4 insertions(+), 8 deletions(-) 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, ) -> Result, 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()),