diff options
author | Harald Musum <musum@yahooinc.com> | 2022-10-27 10:27:19 +0200 |
---|---|---|
committer | Harald Musum <musum@yahooinc.com> | 2022-10-27 10:27:19 +0200 |
commit | 02680001cbce40c69ae1ce9d89835cf09f2e4250 (patch) | |
tree | d73f5e1323eb4d624972bbcd6e8ff94c2a15b91e /configserver | |
parent | 8f1b653565a01513844a156b5d4a7d5eb8e8be23 (diff) |
Delete file reference for application immediately after being copied
Diffstat (limited to 'configserver')
-rw-r--r-- | configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionRepository.java | 8 |
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); + } } } |