invalidate single cache file

elastic · Dec 10, 2020 · 58b7bd9 · 58b7bd9
1 parent 6c1a6e9
commit 58b7bd9
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/...apshots/src/main/java/org/elasticsearch/xpack/searchablesnapshots/cache/CacheService.java b/...apshots/src/main/java/org/elasticsearch/xpack/searchablesnapshots/cache/CacheService.java
@@ -318,7 +318,15 @@ protected void doRun() {
  }
  });
  if (cacheFilesToEvict.isEmpty() == false) {
- cacheFilesToEvict.forEach(cache::invalidate);
+ for (Map.Entry<CacheKey, CacheFile> cacheFile : cacheFilesToEvict.entrySet()) {
+ try {
+ cache.invalidate(cacheFile.getKey(), cacheFile.getValue());
+ } catch (Exception e) {
+ assert e instanceof IOException : e;
+ logger.warn(() -> new ParameterizedMessage("failed to evict cache file {}", cacheFile.getKey()), e);
+ }
+
+ }
  }
  });
  }