diff options
author | Jon Bratseth <bratseth@gmail.com> | 2020-11-09 13:37:45 +0100 |
---|---|---|
committer | Jon Bratseth <bratseth@gmail.com> | 2020-11-09 13:37:45 +0100 |
commit | b264a837674b87a5b4f58e1d513e1c5cd48a7dd1 (patch) | |
tree | 9e9f5cb1bfc2795f7a03d6e1bc500230fe33853d /node-repository | |
parent | 860a24bb85a474e88264bf84082339f677fa12f1 (diff) |
Better name
Diffstat (limited to 'node-repository')
-rw-r--r-- | node-repository/src/main/java/com/yahoo/vespa/hosted/provision/autoscale/QuestMetricsDb.java | 6 |
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); |