Repository: flink Updated Branches: refs/heads/release-1.3 ef63f4adb -> 0aa710a2d
[FLINK-7405] [metrics] Reduce excessive warning logging from DatadogHttpReporter Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0aa710a2 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0aa710a2 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/0aa710a2 Branch: refs/heads/release-1.3 Commit: 0aa710a2d11a1c892cd233ffe487439e7fe915ba Parents: ef63f4a Author: Bowen Li <bowenl...@gmail.com> Authored: Wed Aug 9 14:11:16 2017 -0700 Committer: zentol <ches...@apache.org> Committed: Tue Aug 15 13:54:07 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/0aa710a2/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 fcb5c4b..0d6c657 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 @@ -30,6 +30,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); }
