diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2023-08-31 17:43:32 +0200 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2023-08-31 18:19:21 +0200 |
commit | 3a434180ab6acf7a8b882c978f4048e9a1c75f9e (patch) | |
tree | b6b729147432189641741a6c9f27b49569700edd /node-repository | |
parent | 17b93b6ef0d7225723394def1e832ef37a517231 (diff) |
6.6.1
Diffstat (limited to 'node-repository')
-rw-r--r-- | node-repository/src/main/java/com/yahoo/vespa/hosted/provision/autoscale/QuestMetricsDb.java | 5 |
1 files changed, 1 insertions, 4 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 e0199b5ddaf..717341b7923 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 @@ -8,7 +8,6 @@ import com.yahoo.component.AbstractComponent; import com.yahoo.config.provision.ApplicationId; import com.yahoo.config.provision.ClusterSpec; import com.yahoo.io.IOUtils; -import com.yahoo.vespa.defaults.Defaults; import com.yahoo.yolean.concurrent.ConcurrentResourcePool; import io.questdb.cairo.CairoEngine; import io.questdb.cairo.CairoException; @@ -18,7 +17,6 @@ import io.questdb.cairo.sql.Record; import io.questdb.cairo.sql.RecordCursor; import io.questdb.cairo.sql.RecordCursorFactory; import io.questdb.griffin.CompiledQuery; -import io.questdb.griffin.QueryFuture; import io.questdb.griffin.SqlCompiler; import io.questdb.griffin.SqlException; import io.questdb.griffin.SqlExecutionContext; @@ -40,7 +38,6 @@ import java.util.Set; import java.util.concurrent.atomic.AtomicBoolean; import java.util.logging.Level; import java.util.logging.Logger; -import java.util.stream.Collectors; import static com.yahoo.vespa.defaults.Defaults.getDefaults; @@ -349,7 +346,7 @@ public class QuestMetricsDb extends AbstractComponent implements MetricsDb { * Needs to be done for some queries, e.g. 'alter table' queries, see https://github.com/questdb/questdb/issues/1846 */ private void issueAsync(String sql, SqlExecutionContext context) throws SqlException { - try (QueryFuture future = issue(sql, context).execute(null)) { + try (var future = issue(sql, context).execute(null)) { future.await(); } } |