Repository: flink Updated Branches: refs/heads/master 9a2057310 -> 7f9580061
[hotfix] [metrics] Prevent log flooding from collisions This closes #2135 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7f958006 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7f958006 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/7f958006 Branch: refs/heads/master Commit: 7f9580061177e81b8969bb071db0e21d588beda6 Parents: 9a20573 Author: zentol <ches...@apache.org> Authored: Mon Jun 20 11:26:18 2016 +0200 Committer: zentol <ches...@apache.org> Committed: Fri Jul 15 11:58:15 2016 +0200 ---------------------------------------------------------------------- .../main/java/org/apache/flink/metrics/reporter/JMXReporter.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/7f958006/flink-core/src/main/java/org/apache/flink/metrics/reporter/JMXReporter.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/metrics/reporter/JMXReporter.java b/flink-core/src/main/java/org/apache/flink/metrics/reporter/JMXReporter.java index 2effb5b..0e4aabd 100644 --- a/flink-core/src/main/java/org/apache/flink/metrics/reporter/JMXReporter.java +++ b/flink-core/src/main/java/org/apache/flink/metrics/reporter/JMXReporter.java @@ -167,7 +167,8 @@ public class JMXReporter implements MetricReporter { // implementation error on our side LOG.error("Metric did not comply with JMX MBean naming rules.", e); } catch (InstanceAlreadyExistsException e) { - LOG.error("A metric with the name " + jmxName + " was already registered.", e); + LOG.debug("A metric with the name " + jmxName + " was already registered.", e); + LOG.error("A metric with the name " + jmxName + " was already registered."); } catch (Throwable t) { LOG.error("Failed to register metric", t); }
