diff --git a/plugin/trino-prometheus/src/main/java/io/trino/plugin/prometheus/PrometheusSplitManager.java b/plugin/trino-prometheus/src/main/java/io/trino/plugin/prometheus/PrometheusSplitManager.java index ad77c030d66c..a3d16ef88178 100644 --- a/plugin/trino-prometheus/src/main/java/io/trino/plugin/prometheus/PrometheusSplitManager.java +++ b/plugin/trino-prometheus/src/main/java/io/trino/plugin/prometheus/PrometheusSplitManager.java @@ -59,6 +59,7 @@ public class PrometheusSplitManager implements ConnectorSplitManager { static final long OFFSET_MILLIS = 1L; + static final String QUERY_ENDPOINT = "/api/v1/query"; private final PrometheusClient prometheusClient; private final PrometheusClock prometheusClock; @@ -118,8 +119,7 @@ private static URI buildQuery(URI baseURI, String time, String metricName, Durat nameValuePairs.add(new BasicNameValuePair("query", metricName + "[" + queryChunkSizeDuration.roundTo(queryChunkSizeDuration.getUnit()) + Duration.timeUnitToString(queryChunkSizeDuration.getUnit()) + "]")); nameValuePairs.add(new BasicNameValuePair("time", time)); - return new URIBuilder(baseURI.toString()) - .setPath("api/v1/query") + return new URIBuilder(baseURI.toString() + QUERY_ENDPOINT) .setParameters(nameValuePairs) .build(); }