You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2017/08/15 11:55:02 UTC
flink git commit: [FLINK-7405] [metrics] Reduce excessive warning
logging from DatadogHttpReporter
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 <bo...@gmail.com>
Authored: Wed Aug 9 14:11:16 2017 -0700
Committer: zentol <ch...@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);
}