Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Changed downloadStartMarker in OmniSegmentLoader to simply use its .delete() method

This commit is contained in:
Charles Allen 2014-11-13 08:56:11 -08:00 committed by Xavier Léauté
parent 8cc48fc730
commit 3cdcf8736f
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
server/src/main/java/io/druid/segment/loading/OmniSegmentLoader.java
View File

@ -138,13 +138,11 @@ public class OmniSegmentLoader implements SegmentLoader
getPuller(segment.getLoadSpec()).getSegmentFiles(segment, storageDir); getPuller(segment.getLoadSpec()).getSegmentFiles(segment, storageDir);
try { if (!downloadStartMarker.delete()) {
FileUtils.deleteDirectory(downloadStartMarker);
}
catch (Exception e) {
throw new SegmentLoadingException("Unable to remove marker file for [%s]", storageDir); throw new SegmentLoadingException("Unable to remove marker file for [%s]", storageDir);
} }
loc.addSegment(segment); loc.addSegment(segment);
retVal = storageDir; retVal = storageDir;