You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ambari.apache.org by sw...@apache.org on 2015/08/03 20:13:02 UTC
ambari git commit: AMBARI-10904. Provide a configurable timeout
setting on MetricsTimelineSink.emitMetrics. Sink timeout jetty issue.
(swagle)
Repository: ambari
Updated Branches:
refs/heads/branch-2.0.maint bf0b6cb7f -> fc7f513a3
AMBARI-10904. Provide a configurable timeout setting on MetricsTimelineSink.emitMetrics. Sink timeout jetty issue. (swagle)
Project: http://git-wip-us.apache.org/repos/asf/ambari/repo
Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/fc7f513a
Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/fc7f513a
Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/fc7f513a
Branch: refs/heads/branch-2.0.maint
Commit: fc7f513a3f03313d6a3b39bf2ef082ccd6695524
Parents: bf0b6cb
Author: Siddharth Wagle <sw...@hortonworks.com>
Authored: Mon Aug 3 11:07:37 2015 -0700
Committer: Siddharth Wagle <sw...@hortonworks.com>
Committed: Mon Aug 3 11:12:53 2015 -0700
----------------------------------------------------------------------
.../metrics2/sink/timeline/AbstractTimelineMetricsSink.java | 7 +++++--
1 file changed, 5 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ambari/blob/fc7f513a/ambari-metrics/ambari-metrics-common/src/main/java/org/apache/hadoop/metrics2/sink/timeline/AbstractTimelineMetricsSink.java
----------------------------------------------------------------------
diff --git a/ambari-metrics/ambari-metrics-common/src/main/java/org/apache/hadoop/metrics2/sink/timeline/AbstractTimelineMetricsSink.java b/ambari-metrics/ambari-metrics-common/src/main/java/org/apache/hadoop/metrics2/sink/timeline/AbstractTimelineMetricsSink.java
index 4b93f50..f18f52a 100644
--- a/ambari-metrics/ambari-metrics-common/src/main/java/org/apache/hadoop/metrics2/sink/timeline/AbstractTimelineMetricsSink.java
+++ b/ambari-metrics/ambari-metrics-common/src/main/java/org/apache/hadoop/metrics2/sink/timeline/AbstractTimelineMetricsSink.java
@@ -54,6 +54,8 @@ public abstract class AbstractTimelineMetricsSink {
public AbstractTimelineMetricsSink() {
LOG = LogFactory.getLog(this.getClass());
+ httpClient.getParams().setSoTimeout(getTimeoutSeconds() * 1000);
+ httpClient.getParams().setConnectionManagerTimeout(getTimeoutSeconds() * 1000);
}
protected void emitMetrics(TimelineMetrics metrics) throws IOException {
@@ -65,10 +67,11 @@ public abstract class AbstractTimelineMetricsSink {
PostMethod postMethod = new PostMethod(connectUrl);
postMethod.setRequestEntity(requestEntity);
- postMethod.setParameter(HttpMethodParams.SO_TIMEOUT, String.valueOf(getTimeoutSeconds() * 1000));
int statusCode = httpClient.executeMethod(postMethod);
+
if (statusCode != 200) {
- LOG.info("Unable to POST metrics to collector, " + connectUrl);
+ LOG.info("Unable to POST metrics to collector, " + connectUrl + ", " +
+ "statusCode = " + statusCode);
} else {
LOG.debug("Metrics posted to Collector " + connectUrl);
}