aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2021-11-15 10:15:09 +0100
committerGitHub <noreply@github.com>2021-11-15 10:15:09 +0100
commit958567df05ad3b168a0a1f83813d1385a18b5122 (patch)
treec971ad4b405be90dc72ab5daaa9185eb2a620b60
parent5d57b92c393693104d474c6eb06a23b5c5c2a0c8 (diff)
parent973991beb67d276e4488d2143c25f73e811438d6 (diff)
Merge pull request #20003 from vespa-engine/hmusum/download-logging
Improve file download logging a bit
-rw-r--r--configserver/src/main/java/com/yahoo/vespa/config/server/maintenance/ApplicationPackageMaintainer.java19
-rw-r--r--filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileReferenceDownloader.java4
2 files changed, 11 insertions, 12 deletions
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/maintenance/ApplicationPackageMaintainer.java b/configserver/src/main/java/com/yahoo/vespa/config/server/maintenance/ApplicationPackageMaintainer.java
index d4d4a7fa7d3..5702a6b78cf 100644
--- a/configserver/src/main/java/com/yahoo/vespa/config/server/maintenance/ApplicationPackageMaintainer.java
+++ b/configserver/src/main/java/com/yahoo/vespa/config/server/maintenance/ApplicationPackageMaintainer.java
@@ -61,25 +61,24 @@ public class ApplicationPackageMaintainer extends ConfigServerMaintainer {
try (var fileDownloader = createFileDownloader()) {
for (var applicationId : applicationRepository.listApplications()) {
- log.fine(() -> "Verifying application package for " + applicationId);
+ log.finest(() -> "Verifying application package for " + applicationId);
Session session = applicationRepository.getActiveSession(applicationId);
if (session == null) continue; // App might be deleted after call to listApplications() or not activated yet (bootstrap phase)
- FileReference applicationPackage = session.getApplicationPackageReference();
- long sessionId = session.getSessionId();
- log.fine(() -> "Verifying application package file reference " + applicationPackage + " for session " + sessionId);
-
- if (applicationPackage != null) {
+ FileReference appFileReference = session.getApplicationPackageReference();
+ if (appFileReference != null) {
+ long sessionId = session.getSessionId();
attempts++;
- if (! fileReferenceExistsOnDisk(downloadDirectory, applicationPackage)) {
- log.fine(() -> "Downloading missing application package for application " + applicationId + " (session " + sessionId + ")");
+ if (! fileReferenceExistsOnDisk(downloadDirectory, appFileReference)) {
+ log.fine(() -> "Downloading application package for " + applicationId + " (session " + sessionId + ")");
- FileReferenceDownload download = new FileReferenceDownload(applicationPackage,
+ FileReferenceDownload download = new FileReferenceDownload(appFileReference,
false,
this.getClass().getSimpleName());
if (fileDownloader.getFile(download).isEmpty()) {
failures++;
- log.warning("Failed to download application package for application " + applicationId + " (session " + sessionId + ")");
+ log.warning("Failed to download application package (" + appFileReference + ")" +
+ "for " + applicationId + " (session " + sessionId + ")");
continue;
}
}
diff --git a/filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileReferenceDownloader.java b/filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileReferenceDownloader.java
index 445106f4fe4..8a968fbdca2 100644
--- a/filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileReferenceDownloader.java
+++ b/filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileReferenceDownloader.java
@@ -105,9 +105,9 @@ public class FileReferenceDownloader {
return false;
}
} else {
- log.log(logLevel, () -> "Downloading file " + fileReference + " from " + connection.getAddress() + " failed: " +
+ log.log(logLevel, "Downloading file " + fileReference + " from " + connection.getAddress() + " failed: " +
request + ", error: " + request.errorMessage() + ", will use another config server for next request" +
- " (retry count " + retryCount + ", rpc timeout " + rpcTimeout.getSeconds() + ")");
+ " (retry " + retryCount + ", rpc timeout " + timeoutSecs + " seconds)");
connectionPool.switchConnection(connection);
return false;
}