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 2019/08/22 10:24:57 UTC
[flink] branch release-1.9 updated: [FLINK-13806][metrics] Log all
errors on DEBUG
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 <ch...@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);
}
}