Remove unused code

trinodb · Feb 9, 2024 · c2d8bad · c2d8bad
1 parent cf4c90f
commit c2d8bad
Show file tree

Hide file tree

Showing 4 changed files with 0 additions and 20 deletions.
diff --git a/gateway-ha/gateway-ha-config-docker.yml b/gateway-ha/gateway-ha-config-docker.yml
@@ -32,10 +32,6 @@ server:
       port: 8091
       useForwardedHeaders: true
 
-# This can be adjusted based on the coordinator state
-monitor:
-  connectionTimeout: 15
-
 modules:
   - io.trino.gateway.ha.module.HaGatewayProviderModule
   - io.trino.gateway.ha.module.ClusterStateListenerModule

diff --git a/gateway-ha/gateway-ha-config.yml b/gateway-ha/gateway-ha-config.yml
@@ -32,10 +32,6 @@ server:
       port: 8091
       useForwardedHeaders: true
 
-# This can be adjusted based on the coordinator state
-monitor:
-  connectionTimeout: 15
-
 modules:
   - io.trino.gateway.ha.module.HaGatewayProviderModule
   - io.trino.gateway.ha.module.ClusterStateListenerModule

diff --git a/gateway-ha/src/main/java/io/trino/gateway/ha/clustermonitor/ActiveClusterMonitor.java b/gateway-ha/src/main/java/io/trino/gateway/ha/clustermonitor/ActiveClusterMonitor.java
@@ -31,7 +31,6 @@
 public class ActiveClusterMonitor
         implements Managed
 {
-    public static final int BACKEND_CONNECT_TIMEOUT_SECONDS = 15;
     public static final int MONITOR_TASK_DELAY_MIN = 1;
     public static final int DEFAULT_THREAD_POOL_SIZE = 20;
     private static final Logger log = LoggerFactory.getLogger(ActiveClusterMonitor.class);

diff --git a/gateway-ha/src/main/java/io/trino/gateway/ha/config/MonitorConfiguration.java b/gateway-ha/src/main/java/io/trino/gateway/ha/config/MonitorConfiguration.java
@@ -17,21 +17,10 @@
 
 public class MonitorConfiguration
 {
-    private int connectionTimeout = ActiveClusterMonitor.BACKEND_CONNECT_TIMEOUT_SECONDS;
     private int taskDelayMin = ActiveClusterMonitor.MONITOR_TASK_DELAY_MIN;
 
     public MonitorConfiguration() {}
 
-    public int getConnectionTimeout()
-    {
-        return this.connectionTimeout;
-    }
-
-    public void setConnectionTimeout(int connectionTimeout)
-    {
-        this.connectionTimeout = connectionTimeout;
-    }
-
     public int getTaskDelayMin()
     {
         return this.taskDelayMin;