DefaultJobStatusStore implements JobStatusStore, Initializable { @Override public void remove(List<String> id) { this.writeLock.lock(); try { File jobFolder = getJobFolder(id); if (jobFolder.exists()) { try { FileUtils.deleteDirectory(jobFolder); } catch (IOException e) { this.logger.warn("Failed to delete job folder [{}]", jobFolder, e); } } this.cache.remove(toUniqueString(id)); } finally { this.writeLock.unlock(); } }  @Override void initialize(); @Override JobStatus getJobStatus(List<String> id); @Override void store(JobStatus status); @Override void storeAsync(JobStatus status); @Override void remove(List<String> id); @Override LoggerTail createLoggerTail(List<String> jobId, boolean readonly); void flushCache();  }
@Test void removeNotExistingJobStatus() { this.store.remove(Arrays.asList("notexist")); }