mirror of
https://github.com/openobserve/openobserve.git
synced 2026-11-04 16:09:05 +00:00
fix: aggs cache ratio reporting (#8984)
Signed-off-by: loaki07 <rustyloaki@gmail.com>
This commit is contained in:
@@ -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 }))
|
||||
}
|
||||
|
||||
@@ -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()),
|
||||
|
||||
Reference in New Issue
Block a user