diff --git a/gateway-ha/gateway-ha-config-docker.yml b/gateway-ha/gateway-ha-config-docker.yml index 60c9d3f4d..4c7e8f587 100644 --- 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 index 815ba9bf4..d60d4ec4d 100644 --- 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 index c61d40e18..45e7ba8c3 100644 --- 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 index fe5cb71bc..040827635 100644 --- 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;