Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 0 additions & 4 deletions gateway-ha/gateway-ha-config-docker.yml
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
4 changes: 0 additions & 4 deletions gateway-ha/gateway-ha-config.yml
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down