diff options
author | valerijf <valerijf@yahoo-inc.com> | 2017-06-22 17:32:02 +0200 |
---|---|---|
committer | valerijf <valerijf@yahoo-inc.com> | 2017-06-22 17:32:02 +0200 |
commit | 8d818137d848bba002f9729e4210b89718389606 (patch) | |
tree | b91a287a8ee68760d8ef4dec5c45a4c612ee273f /node-admin | |
parent | 7eeea0b0073e7f13f1047eba1523995ed67de6be (diff) |
Increase push frequency and rpc timeout
Diffstat (limited to 'node-admin')
-rw-r--r-- | node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeadmin/NodeAdminImpl.java | 2 | ||||
-rw-r--r-- | node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeagent/NodeAgentImpl.java | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeadmin/NodeAdminImpl.java b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeadmin/NodeAdminImpl.java index 84679d1dadd..28a6fb91c19 100644 --- a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeadmin/NodeAdminImpl.java +++ b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeadmin/NodeAdminImpl.java @@ -87,7 +87,7 @@ public class NodeAdminImpl implements NodeAdmin { } catch (Throwable e) { logger.warning("Metric fetcher scheduler failed", e); } - }, 0, 55, TimeUnit.SECONDS); + }, 0, 40, TimeUnit.SECONDS); aclMaintainer.ifPresent(maintainer -> aclScheduler.scheduleWithFixedDelay(() -> { if (!isFrozen()) maintainer.run(); diff --git a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeagent/NodeAgentImpl.java b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeagent/NodeAgentImpl.java index 6145e2e372e..c217128675b 100644 --- a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeagent/NodeAgentImpl.java +++ b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeagent/NodeAgentImpl.java @@ -577,7 +577,7 @@ public class NodeAgentImpl implements NodeAgent { String wrappedMetrics = "s:" + params.toString(); // Push metrics to the metrics proxy in each container - give it maximum 1 seconds to complete - String[] command = {"rpc_invoke", "-t", "1", "tcp/localhost:19091", "setExtraMetrics", wrappedMetrics}; + String[] command = {"rpc_invoke", "-t", "2", "tcp/localhost:19091", "setExtraMetrics", wrappedMetrics}; dockerOperations.executeCommandInContainerAsRoot(containerName, 5L, command); } catch (DockerExecTimeoutException | JsonProcessingException e) { logger.warning("Unable to push metrics to container: " + containerName, e); |