[flink] branch release-1.9 updated: [FLINK-13806][metrics] Log all errors on DEBUG

[chesnay]

This is an automated email from the ASF dual-hosted git repository.

chesnay pushed a commit to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.9 by this push:
     new d708ab2  [FLINK-13806][metrics] Log all errors on DEBUG
d708ab2 is described below

commit d708ab222846735b4ec4562fe8609389cb616da2
Author: Chesnay Schepler <ches...@apache.org>
AuthorDate: Thu Aug 22 09:42:28 2019 +0200

    [FLINK-13806][metrics] Log all errors on DEBUG
---
 .../runtime/rest/handler/legacy/metrics/MetricFetcherImpl.java      | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/metrics/MetricFetcherImpl.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/metrics/MetricFetcherImpl.java
index b9250d6..f157006 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/metrics/MetricFetcherImpl.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/metrics/MetricFetcherImpl.java
@@ -139,7 +139,7 @@ public class MetricFetcherImpl<T extends RestfulGateway> 
implements MetricFetche
                                queryServiceAddressesFuture.whenCompleteAsync(
                                        (Collection<String> 
queryServiceAddresses, Throwable throwable) -> {
                                                if (throwable != null) {
-                                                       LOG.warn("Requesting 
paths for query services failed.", throwable);
+                                                       LOG.debug("Requesting 
paths for query services failed.", throwable);
                                                } else {
                                                        for (String 
queryServiceAddress : queryServiceAddresses) {
                                                                
retrieveAndQueryMetrics(queryServiceAddress);
@@ -157,7 +157,7 @@ public class MetricFetcherImpl<T extends RestfulGateway> 
implements MetricFetche
                                
taskManagerQueryServiceGatewaysFuture.whenCompleteAsync(
                                        (Collection<Tuple2<ResourceID, String>> 
queryServiceGateways, Throwable throwable) -> {
                                                if (throwable != null) {
-                                                       LOG.warn("Requesting 
TaskManager's path for query services failed.", throwable);
+                                                       LOG.debug("Requesting 
TaskManager's path for query services failed.", throwable);
                                                } else {
                                                        List<String> 
taskManagersToRetain = queryServiceGateways
                                                                .stream()
@@ -175,7 +175,7 @@ public class MetricFetcherImpl<T extends RestfulGateway> 
implements MetricFetche
                                        executor);
                        }
                } catch (Exception e) {
-                       LOG.warn("Exception while fetching metrics.", e);
+                       LOG.debug("Exception while fetching metrics.", e);
                }
        }