summaryrefslogtreecommitdiffstats
path: root/metrics-proxy
diff options
context:
space:
mode:
authorOla Aunrønning <olaa@verizonmedia.com>2021-02-10 12:51:07 +0100
committerOla Aunrønning <olaa@verizonmedia.com>2021-02-10 12:51:07 +0100
commit73ef2d30c4e8962ab8108ca1f900a96e08f2a9bd (patch)
treed28221ed519f62480e203e26cd10499da7f5b508 /metrics-proxy
parentacb78cba6ee4372f5734ed3ad4351762c70c5021 (diff)
Ignore dimensions with null key or value
Diffstat (limited to 'metrics-proxy')
-rw-r--r--metrics-proxy/src/main/java/ai/vespa/metricsproxy/metric/model/json/YamasJsonUtil.java10
1 files changed, 7 insertions, 3 deletions
diff --git a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/metric/model/json/YamasJsonUtil.java b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/metric/model/json/YamasJsonUtil.java
index d71b11a4ff2..4413a9ebc2e 100644
--- a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/metric/model/json/YamasJsonUtil.java
+++ b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/metric/model/json/YamasJsonUtil.java
@@ -108,9 +108,13 @@ public class YamasJsonUtil {
if (packet.dimensions().isEmpty()) model.dimensions = null;
else {
- model.dimensions = packet.dimensions().entrySet().stream().collect(
- toLinkedMap(id2dim -> id2dim.getKey().id,
- Map.Entry::getValue));
+ model.dimensions = packet.dimensions().entrySet()
+ .stream()
+ .filter(entry -> entry.getKey() != null && entry.getValue() != null)
+ .collect(toLinkedMap(
+ id2dim -> id2dim.getKey().id,
+ Map.Entry::getValue)
+ );
}
YamasJsonModel.YamasJsonNamespace namespaces = toYamasJsonNamespaces(packet.consumers());