Remove unused field

trinodb · Feb 10, 2024 · 230439e · 230439e
1 parent c2d8bad
commit 230439e
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 10 deletions.
diff --git a/gateway-ha/src/main/java/io/trino/gateway/ha/clustermonitor/ClusterStats.java b/gateway-ha/src/main/java/io/trino/gateway/ha/clustermonitor/ClusterStats.java
@@ -23,7 +23,6 @@ public record ClusterStats(
         String clusterId,
         int runningQueryCount,
         int queuedQueryCount,
-        int blockedQueryCount,
         int numWorkerNodes,
         boolean healthy,
         String proxyTo,
@@ -41,7 +40,6 @@ public static final class Builder
         private final String clusterId;
         private int runningQueryCount;
         private int queuedQueryCount;
-        private int blockedQueryCount;
         private int numWorkerNodes;
         private boolean healthy;
         private String proxyTo;
@@ -66,12 +64,6 @@ public Builder queuedQueryCount(int queuedQueryCount)
             return this;
         }
 
-        public Builder blockedQueryCount(int blockedQueryCount)
-        {
-            this.blockedQueryCount = blockedQueryCount;
-            return this;
-        }
-
         public Builder numWorkerNodes(int numWorkerNodes)
         {
             this.numWorkerNodes = numWorkerNodes;
@@ -114,7 +106,6 @@ public ClusterStats build()
                     clusterId,
                     runningQueryCount,
                     queuedQueryCount,
-                    blockedQueryCount,
                     numWorkerNodes,
                     healthy,
                     proxyTo,

diff --git a/gateway-ha/src/main/java/io/trino/gateway/ha/clustermonitor/ClusterStatsHttpMonitor.java b/gateway-ha/src/main/java/io/trino/gateway/ha/clustermonitor/ClusterStatsHttpMonitor.java
@@ -73,7 +73,6 @@ public ClusterStats monitor(ProxyBackendConfiguration backend)
                     .numWorkerNodes(activeWorkers)
                     .queuedQueryCount((int) result.get("queuedQueries"))
                     .runningQueryCount((int) result.get("runningQueries"))
-                    .blockedQueryCount((int) result.get("blockedQueries"))
                     .healthy(activeWorkers > 0)
                     .proxyTo(backend.getProxyTo())
                     .externalUrl(backend.getExternalUrl())