@Override
  public void invalidateCaches() {
    boolean isEmpty = true;

    if (Files.exists(PersistentUtil.LOG_CACHE)) {
      try (DirectoryStream<Path> stream = Files.newDirectoryStream(PersistentUtil.LOG_CACHE)) {
        if (stream.iterator().hasNext()) {
          isEmpty = false;
        }
      }
      catch (IOException ignored) {
      }
    }

    if (!isEmpty) {
      try {
        Files.createFile(NioFiles.createParentDirectories(PersistentUtil.getCorruptionMarkerFile()));
      }
      catch (Exception e) {
        LOG.error(e);
      }
    }
  }
@Override
  public void invalidateCaches()