diff --git a/java/src/main/java/monasca/persister/repository/influxdb/InfluxPoint.java b/java/src/main/java/monasca/persister/repository/influxdb/InfluxPoint.java index ecd9f8ab..2d25152b 100644 --- a/java/src/main/java/monasca/persister/repository/influxdb/InfluxPoint.java +++ b/java/src/main/java/monasca/persister/repository/influxdb/InfluxPoint.java @@ -21,37 +21,42 @@ import java.util.Map; public class InfluxPoint { - private final String name; + private final String measurement; private final Map tags; - private final String timestamp; + private final String time; private final Map fields; + private final String Precision = "ms"; public InfluxPoint( - final String name, + final String measurement, final Map tags, - final String timestamp, + final String time, final Map fields) { - this.name = name; + this.measurement = measurement; this.tags = tags; - this.timestamp = timestamp; + this.time = time; this.fields = fields; } - public String getName() { - return name; + public String getMeasurement() { + return measurement; } public Map getTags() { return this.tags; } - public String getTimestamp() { - return this.timestamp; + public String getTime() { + return this.time; } public Map getFields() { return this.fields; } + public String getPrecision() { + return Precision; + } + } diff --git a/java/src/main/java/monasca/persister/repository/influxdb/InfluxV9RepoWriter.java b/java/src/main/java/monasca/persister/repository/influxdb/InfluxV9RepoWriter.java index 27e63bbf..273176e4 100644 --- a/java/src/main/java/monasca/persister/repository/influxdb/InfluxV9RepoWriter.java +++ b/java/src/main/java/monasca/persister/repository/influxdb/InfluxV9RepoWriter.java @@ -185,7 +185,7 @@ public class InfluxV9RepoWriter { int rc = response.getStatusLine().getStatusCode(); - if (rc != HttpStatus.SC_OK) { + if (rc != HttpStatus.SC_OK && rc != HttpStatus.SC_NO_CONTENT) { logger.error("[{}]: failed to send data to influxdb {} at {}: {}", id, this.influxName, this.influxUrl, String.valueOf(rc));