[FLINK-7405] [metrics] Reduce excessive warning logging from DatadogHttpReporter
This closes #4508. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3b0321ae Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3b0321ae Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/3b0321ae Branch: refs/heads/master Commit: 3b0321aee4a409658399b53d8ff77b872e61e42c Parents: be196f7 Author: Bowen Li <bowenl...@gmail.com> Authored: Wed Aug 9 14:11:16 2017 -0700 Committer: zentol <ches...@apache.org> Committed: Tue Aug 15 12:38:14 2017 +0200 ---------------------------------------------------------------------- .../org/apache/flink/metrics/datadog/DatadogHttpReporter.java | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/3b0321ae/flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics/datadog/DatadogHttpReporter.java ---------------------------------------------------------------------- diff --git a/flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics/datadog/DatadogHttpReporter.java b/flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics/datadog/DatadogHttpReporter.java index a47b2bf..b7e1c24 100644 --- a/flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics/datadog/DatadogHttpReporter.java +++ b/flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics/datadog/DatadogHttpReporter.java @@ -31,6 +31,7 @@ import org.apache.flink.metrics.reporter.Scheduled; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import java.net.SocketTimeoutException; import java.util.ArrayList; import java.util.Arrays; import java.util.List; @@ -140,6 +141,8 @@ public class DatadogHttpReporter implements MetricReporter, Scheduled { try { client.send(request); + } catch (SocketTimeoutException e) { + LOGGER.warn("Failed reporting metrics to Datadog because of socket timeout.", e.getMessage()); } catch (Exception e) { LOGGER.warn("Failed reporting metrics to Datadog.", e); }
