diff --git a/processing/src/main/java/io/druid/query/DruidMetrics.java b/processing/src/main/java/io/druid/query/DruidMetrics.java index 58deed81f2d..731dd27d4ac 100644 --- a/processing/src/main/java/io/druid/query/DruidMetrics.java +++ b/processing/src/main/java/io/druid/query/DruidMetrics.java @@ -20,6 +20,7 @@ package io.druid.query; import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.ObjectMapper; import com.google.common.base.Function; +import com.google.common.base.Strings; import com.google.common.collect.ImmutableMap; import com.google.common.collect.Lists; import com.metamx.emitter.service.ServiceMetricEvent; @@ -37,6 +38,7 @@ public class DruidMetrics public final static String INTERVAL = "interval"; public final static String ID = "id"; public final static String STATUS = "status"; + public final static String VERSION = "version"; // task metrics public final static String TASK_TYPE = "taskType"; @@ -59,6 +61,7 @@ public class DruidMetrics public static ServiceMetricEvent.Builder makePartialQueryTimeMetric(Query query) { return new ServiceMetricEvent.Builder() + .setDimension(VERSION, Strings.nullToEmpty(DruidMetrics.class.getPackage().getImplementationVersion())) .setDimension(DATASOURCE, DataSourceUtil.getMetricName(query.getDataSource())) .setDimension(TYPE, query.getType()) .setDimension(