summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorHarald Musum <musum@yahooinc.com>2022-10-27 10:27:19 +0200
committerHarald Musum <musum@yahooinc.com>2022-10-27 10:27:19 +0200
commit02680001cbce40c69ae1ce9d89835cf09f2e4250 (patch)
treed73f5e1323eb4d624972bbcd6e8ff94c2a15b91e
parent8f1b653565a01513844a156b5d4a7d5eb8e8be23 (diff)
Delete file reference for application immediately after being copied
-rw-r--r--configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionRepository.java8
1 files changed, 7 insertions, 1 deletions
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionRepository.java b/configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionRepository.java
index 15be909c069..89ca0265008 100644
--- a/configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionRepository.java
+++ b/configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionRepository.java
@@ -898,7 +898,13 @@ public class SessionRepository {
ApplicationId applicationId = sessionZKClient.readApplicationId()
.orElseThrow(() -> new RuntimeException("Could not find application id for session " + sessionId));
log.log(Level.FINE, () -> "Creating local session for tenant '" + tenantName + "' with session id " + sessionId);
- createLocalSession(sessionDir, applicationId, sessionZKClient.readTags(), sessionId);
+ try {
+ createLocalSession(sessionDir, applicationId, sessionZKClient.readTags(), sessionId);
+ } finally {
+ // Delete downloaded file reference, not needed anymore
+ log.log(Level.FINE, "Deleting file distribution reference for app package with session id " + sessionDir);
+ IOUtils.recursiveDeleteDir(sessionDir);
+ }
}
}