We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 0b43242 commit 2474104Copy full SHA for 2474104
1 file changed
datafusion/execution/src/cache/cache_unit.rs
@@ -103,16 +103,18 @@ impl DefaultFileStatisticsCacheState {
103
let entry_size = value.heap_size();
104
105
if entry_size + key_size > self.memory_limit {
106
- // Remove stale entry if exists
+ // Remove potential stale entry
107
self.remove(key);
108
return None;
109
}
110
111
let old_value = self.lru_queue.put(key.clone(), value);
112
- self.memory_used += entry_size + key_size;
+ self.memory_used += entry_size;
113
114
if let Some(old_entry) = &old_value {
115
self.memory_used -= old_entry.heap_size();
116
+ } else {
117
+ self.memory_used += key.heap_size();
118
119
120
self.evict_entries();
0 commit comments