From fc9aa8fc34eb379523a142f21f9846212a4d7d6e Mon Sep 17 00:00:00 2001 From: Yuya Ebihara Date: Tue, 30 Jan 2024 19:43:59 +0900 Subject: [PATCH] Remove unused field --- .../gateway/ha/clustermonitor/ActiveClusterMonitor.java | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) 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 35fd4c026..c61d40e18 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 @@ -38,7 +38,6 @@ public class ActiveClusterMonitor private final List clusterStatsObservers; private final GatewayBackendManager gatewayBackendManager; - private final int connectionTimeout; private final int taskDelayMin; private final ClusterStatsMonitor clusterStatsMonitor; private volatile boolean monitorActive = true; @@ -54,11 +53,9 @@ public ActiveClusterMonitor( { this.clusterStatsObservers = clusterStatsObservers; this.gatewayBackendManager = gatewayBackendManager; - this.connectionTimeout = monitorConfiguration.getConnectionTimeout(); this.taskDelayMin = monitorConfiguration.getTaskDelayMin(); this.clusterStatsMonitor = clusterStatsMonitor; - log.info("Running cluster monitor with connection timeout of {} and task delay of {}", - connectionTimeout, taskDelayMin); + log.info("Running cluster monitor with task delay of {}", taskDelayMin); } /**