diff --git a/src/service/search/cache/mod.rs b/src/service/search/cache/mod.rs index ff2677bf09..9bcec31a18 100644 --- a/src/service/search/cache/mod.rs +++ b/src/service/search/cache/mod.rs @@ -346,6 +346,7 @@ fn merge_response( continue; } resp.hits.extend(res.hits.clone()); + resp.histogram_interval = res.histogram_interval; } resp.took = cache_took; resp diff --git a/src/service/search/cache/multi.rs b/src/service/search/cache/multi.rs index 6004875508..eb8d57418f 100644 --- a/src/service/search/cache/multi.rs +++ b/src/service/search/cache/multi.rs @@ -179,7 +179,7 @@ async fn recursive_process_multiple_metas( let discard_ts = get_allowed_up_to(&cached_response, &cache_req, discard_duration); cached_response.hits.retain(|hit| { let hit_ts = get_ts_value(&cache_req.ts_column, hit); - hit_ts <= hits_allowed_end_time && + hit_ts < hits_allowed_end_time && hit_ts >= hits_allowed_start_time && hit_ts < discard_ts });