Repository: flink Updated Branches: refs/heads/master 0dce0381c -> aaa6c7aed
[hotfix][metrics] Fix typos Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/aaa6c7ae Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/aaa6c7ae Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/aaa6c7ae Branch: refs/heads/master Commit: aaa6c7aedadf919f585bfc3a26c2bca71a468450 Parents: 0dce038 Author: zentol <ches...@apache.org> Authored: Fri Jul 8 14:20:46 2016 +0200 Committer: zentol <ches...@apache.org> Committed: Fri Jul 8 14:20:46 2016 +0200 ---------------------------------------------------------------------- .../src/main/java/org/apache/flink/metrics/MetricRegistry.java | 4 ++-- .../main/java/org/apache/flink/metrics/reporter/JMXReporter.java | 2 +- .../test/java/org/apache/flink/metrics/MetricRegistryTest.java | 2 +- 3 files changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/aaa6c7ae/flink-core/src/main/java/org/apache/flink/metrics/MetricRegistry.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/metrics/MetricRegistry.java b/flink-core/src/main/java/org/apache/flink/metrics/MetricRegistry.java index 09beef6..dafa3bd 100644 --- a/flink-core/src/main/java/org/apache/flink/metrics/MetricRegistry.java +++ b/flink-core/src/main/java/org/apache/flink/metrics/MetricRegistry.java @@ -74,13 +74,13 @@ public class MetricRegistry { * Creates a new MetricRegistry and starts the configured reporter. */ public MetricRegistry(Configuration config) { - // first parse the scopeName formats, these are needed for all reporters + // first parse the scope formats, these are needed for all reporters ScopeFormats scopeFormats; try { scopeFormats = createScopeConfig(config); } catch (Exception e) { - LOG.warn("Failed to parse scopeName format, using default scopeName formats", e); + LOG.warn("Failed to parse scope format, using default scope formats", e); scopeFormats = new ScopeFormats(); } this.scopeFormats = scopeFormats; http://git-wip-us.apache.org/repos/asf/flink/blob/aaa6c7ae/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 90a4fcf..bdaf68a 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 @@ -208,7 +208,7 @@ public class JMXReporter implements MetricReporter { nameBuilder.append(x); nameBuilder.append("="); - // write scopeName component + // write scope component nameBuilder.append(replaceInvalidChars(scopeComponents[x])); nameBuilder.append(","); } http://git-wip-us.apache.org/repos/asf/flink/blob/aaa6c7ae/flink-core/src/test/java/org/apache/flink/metrics/MetricRegistryTest.java ---------------------------------------------------------------------- diff --git a/flink-core/src/test/java/org/apache/flink/metrics/MetricRegistryTest.java b/flink-core/src/test/java/org/apache/flink/metrics/MetricRegistryTest.java index 77acd3c..42464ed 100644 --- a/flink-core/src/test/java/org/apache/flink/metrics/MetricRegistryTest.java +++ b/flink-core/src/test/java/org/apache/flink/metrics/MetricRegistryTest.java @@ -157,7 +157,7 @@ public class MetricRegistryTest extends TestLogger { } /** - * Verifies that the scopeName configuration is properly extracted. + * Verifies that the scope configuration is properly extracted. */ @Test public void testScopeConfig() {