diff --git a/java/src/main/java/monasca/persister/repository/InfluxV8MetricRepo.java b/java/src/main/java/monasca/persister/repository/InfluxV8MetricRepo.java index 82714f41..c6fe5fde 100644 --- a/java/src/main/java/monasca/persister/repository/InfluxV8MetricRepo.java +++ b/java/src/main/java/monasca/persister/repository/InfluxV8MetricRepo.java @@ -17,9 +17,10 @@ package monasca.persister.repository; +import com.google.inject.Inject; + import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.ObjectMapper; -import com.google.inject.Inject; import org.influxdb.dto.Serie; import org.slf4j.Logger; @@ -94,7 +95,7 @@ public class InfluxV8MetricRepo extends InfluxMetricRepo logger.debug("Added column value to colValsObjArry[{}] = {}", 2, valueMetaJson); } catch (JsonProcessingException e) { - logger.error("Unable to serialize " + measurement.valueMeta, e); + logger.error("Unable to serialize value meta data {}", measurement.valueMeta, e); } } builder.values(colValsObjArry); diff --git a/java/src/main/java/monasca/persister/repository/InfluxV9MetricRepo.java b/java/src/main/java/monasca/persister/repository/InfluxV9MetricRepo.java index 00f33640..73e1dd37 100644 --- a/java/src/main/java/monasca/persister/repository/InfluxV9MetricRepo.java +++ b/java/src/main/java/monasca/persister/repository/InfluxV9MetricRepo.java @@ -18,11 +18,11 @@ package monasca.persister.repository; +import com.google.inject.Inject; + import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.ObjectMapper; -import com.google.inject.Inject; - import org.joda.time.DateTime; import org.joda.time.DateTimeZone; import org.joda.time.format.DateTimeFormatter; @@ -84,8 +84,8 @@ public class InfluxV9MetricRepo extends InfluxMetricRepo { for (Dim dim : dimSet) { tagMap.put(dim.name, dim.value); } - tagMap.put("tenant_id", def.tenantId); - tagMap.put("region", def.region); + tagMap.put("_tenant_id", def.tenantId); + tagMap.put("_region", def.region); for (final Measurement measurement : this.measurementMap.get(defDimId)) {