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 2016/08/08 13:11:34 UTC
[2/2] flink git commit: [FLINK-4291] [metrics] Add log entry for
scheduled reporters
[FLINK-4291] [metrics] Add log entry for scheduled reporters
This closes #2318
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f1e9daec
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f1e9daec
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/f1e9daec
Branch: refs/heads/master
Commit: f1e9daece516db98aad15818e90e4e3bf78a6e13
Parents: a2219b0
Author: zentol <ch...@apache.org>
Authored: Mon Aug 1 13:57:07 2016 +0200
Committer: zentol <ch...@apache.org>
Committed: Mon Aug 8 15:10:50 2016 +0200
----------------------------------------------------------------------
.../main/java/org/apache/flink/runtime/metrics/MetricRegistry.java | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/f1e9daec/flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricRegistry.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricRegistry.java b/flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricRegistry.java
index 65b5b9b..fb494b2 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricRegistry.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricRegistry.java
@@ -131,6 +131,8 @@ public class MetricRegistry {
executor.scheduleWithFixedDelay(
new ReporterTask((Scheduled) reporterInstance), period, period, timeunit);
+ } else {
+ LOG.info("Reporting metrics for reporter {} of type {}.", namedReporter, className);
}
reporters.add(reporterInstance);
}