|
@@ -269,9 +269,8 @@ public class FileSystemTimelineWriter extends TimelineWriter{
|
|
if (logFDsCache != null) {
|
|
if (logFDsCache != null) {
|
|
LOG.debug("Closing cache");
|
|
LOG.debug("Closing cache");
|
|
logFDsCache.flush();
|
|
logFDsCache.flush();
|
|
- logFDsCache.close();
|
|
|
|
- logFDsCache = null;
|
|
|
|
}
|
|
}
|
|
|
|
+ IOUtils.cleanup(LOG, logFDsCache, fs);
|
|
}
|
|
}
|
|
|
|
|
|
@Override
|
|
@Override
|