diff --git a/flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/MetricConfig.java b/flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/MetricConfig.java index b9fcafb5f2d8a..17e77a0b1d19e 100644 --- a/flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/MetricConfig.java +++ b/flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/MetricConfig.java @@ -33,8 +33,21 @@ @Public public class MetricConfig extends Properties { + /** + * Returns the value associated with the given key as a {@code String}. + * + *
If the value is not a {@link String}, its {@code toString()} representation is returned.
+ *
+ * @param key the hashtable key.
+ * @param defaultValue a default value.
+ * @return the value in this property list with the specified key value as a String.
+ */
public String getString(String key, String defaultValue) {
- return getProperty(key, defaultValue);
+ final Object value = get(key);
+ if (value == null) {
+ return defaultValue;
+ }
+ return value.toString();
}
/**
diff --git a/flink-metrics/flink-metrics-core/src/test/java/org/apache/flink/metrics/MetricConfigTest.java b/flink-metrics/flink-metrics-core/src/test/java/org/apache/flink/metrics/MetricConfigTest.java
index d3be33d966383..2824328c6a5cd 100644
--- a/flink-metrics/flink-metrics-core/src/test/java/org/apache/flink/metrics/MetricConfigTest.java
+++ b/flink-metrics/flink-metrics-core/src/test/java/org/apache/flink/metrics/MetricConfigTest.java
@@ -90,7 +90,14 @@ private static Stream