[FLINK-6440][metrics] Downgrade fetching failure logging to DEBUG

Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5569c4fa
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5569c4fa
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/5569c4fa

Branch: refs/heads/release-1.3
Commit: 5569c4fafb08755ef12b7a96a173170dad883184
Parents: 44be162
Author: zentol <[email protected]>
Authored: Tue May 16 10:19:18 2017 +0200
Committer: zentol <[email protected]>
Committed: Thu May 18 17:42:55 2017 +0200

----------------------------------------------------------------------
 .../org/apache/flink/runtime/webmonitor/metrics/MetricFetcher.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/5569c4fa/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/metrics/MetricFetcher.java
----------------------------------------------------------------------
diff --git 
a/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/metrics/MetricFetcher.java
 
b/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/metrics/MetricFetcher.java
index 7ffadce..4f92148 100644
--- 
a/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/metrics/MetricFetcher.java
+++ 
b/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/metrics/MetricFetcher.java
@@ -169,7 +169,7 @@ public class MetricFetcher {
                future.onFailure(new OnFailure() {
                        @Override
                        public void onFailure(Throwable failure) throws 
Throwable {
-                               LOG.warn(message, failure);
+                               LOG.debug(message, failure);
                        }
                }, ctx);
        }

Reply via email to