aboutsummaryrefslogtreecommitdiffstats
path: root/filedistribution
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2018-02-07 15:33:49 +0100
committerGitHub <noreply@github.com>2018-02-07 15:33:49 +0100
commita8d27af94aa5abf3e20deda9b7f04f5199d56774 (patch)
treebfe091a548b5d1fc14b703df45fce7d6a3a057db /filedistribution
parent2b4bef473156964a50e0785ba93ad122d4512386 (diff)
parentdc9146397a91a7ced8502e2559df4619747c1bea (diff)
Merge pull request #4951 from vespa-engine/hmusum/delete-inprogress-file
Delete inprogress file
Diffstat (limited to 'filedistribution')
-rw-r--r--filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileReceiver.java6
1 files changed, 6 insertions, 0 deletions
diff --git a/filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileReceiver.java b/filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileReceiver.java
index 3d6c7bf0a5c..c95fe73ab4e 100644
--- a/filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileReceiver.java
+++ b/filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileReceiver.java
@@ -129,6 +129,12 @@ public class FileReceiver {
} catch (IOException e) {
log.log(LogLevel.ERROR, "Failed writing file: " + e.getMessage(), e);
throw new RuntimeException("Failed writing file: ", e);
+ } finally {
+ try {
+ Files.delete(inprogressFile.toPath());
+ } catch (IOException e) {
+ log.log(LogLevel.ERROR, "Failed deleting " + inprogressFile.getAbsolutePath() + ": " + e.getMessage(), e);
+ }
}
return file;
}