diff --git a/src/puffin/src/puffin_manager/stager/bounded_stager.rs b/src/puffin/src/puffin_manager/stager/bounded_stager.rs index 476eaf9bb62..d74c9f82133 100644 --- a/src/puffin/src/puffin_manager/stager/bounded_stager.rs +++ b/src/puffin/src/puffin_manager/stager/bounded_stager.rs @@ -26,6 +26,7 @@ use common_runtime::runtime::RuntimeTrait; use common_telemetry::{info, warn}; use futures::{FutureExt, StreamExt}; use moka::future::Cache; +use moka::policy::EvictionPolicy; use sha2::{Digest, Sha256}; use snafu::ResultExt; use tokio::fs; @@ -81,6 +82,7 @@ impl BoundedStager { let cache = Cache::builder() .max_capacity(capacity) .weigher(|_: &String, v: &CacheValue| v.weight()) + .eviction_policy(EvictionPolicy::lru()) .async_eviction_listener(move |k, v, _| { let recycle_bin = recycle_bin_cloned.clone(); async move {