summaryrefslogtreecommitdiffstats
path: root/node-repository
diff options
context:
space:
mode:
authorJon Bratseth <bratseth@gmail.com>2020-11-09 13:37:45 +0100
committerJon Bratseth <bratseth@gmail.com>2020-11-09 13:37:45 +0100
commitb264a837674b87a5b4f58e1d513e1c5cd48a7dd1 (patch)
tree9e9f5cb1bfc2795f7a03d6e1bc500230fe33853d /node-repository
parent860a24bb85a474e88264bf84082339f677fa12f1 (diff)
Better name
Diffstat (limited to 'node-repository')
-rw-r--r--node-repository/src/main/java/com/yahoo/vespa/hosted/provision/autoscale/QuestMetricsDb.java6
1 files changed, 3 insertions, 3 deletions
diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/autoscale/QuestMetricsDb.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/autoscale/QuestMetricsDb.java
index 2cb80a04e33..163ee74e8f1 100644
--- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/autoscale/QuestMetricsDb.java
+++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/autoscale/QuestMetricsDb.java
@@ -114,7 +114,7 @@ public class QuestMetricsDb implements MetricsDb {
// Since we remove full days at once we need to keep at least the scaling window + 1 day
Instant oldestToKeep = clock.instant().minus(Autoscaler.maxScalingWindow().plus(Duration.ofDays(1)));
SqlExecutionContext context = newContext();
- int partitionsFound = 0;
+ int partitions = 0;
try (SqlCompiler compiler = new SqlCompiler(engine)) {
File tableRoot = new File(dataDir, tableName);
List<String> removeList = new ArrayList<>();
@@ -122,7 +122,7 @@ public class QuestMetricsDb implements MetricsDb {
File partitionDir = new File(tableRoot, dirEntry);
if ( ! partitionDir.isDirectory()) continue;
- partitionsFound++;
+ partitions++;
DateTimeFormatter formatter = DateTimeFormatter.ISO_DATE_TIME.withZone(ZoneId.of("UTC"));
Instant partitionDay = Instant.from(formatter.parse(dirEntry + "T00:00:00"));
if (partitionDay.isBefore(oldestToKeep))
@@ -130,7 +130,7 @@ public class QuestMetricsDb implements MetricsDb {
}
// Remove unless all partitions are old: Removing all partitions "will be supported in the future"
- if ( removeList.size() < partitionsFound && ! removeList.isEmpty())
+ if ( removeList.size() < partitions && ! removeList.isEmpty())
compiler.compile("alter table " + tableName + " drop partition " +
removeList.stream().map(dir -> "'" + dir + "'").collect(Collectors.joining(",")),
context);