This is an automated email from the ASF dual-hosted git repository.
riemer pushed a commit to branch dev
in repository
https://gitbox.apache.org/repos/asf/incubator-streampipes-extensions.git
The following commit(s) were added to refs/heads/dev by this push:
new 52f3c96 [STREAMPIPES-394] Fix wrong timestamp extractionin Influx sink
52f3c96 is described below
commit 52f3c960afff4747da1798d2d222a093341d4844
Author: Dominik Riemer <[email protected]>
AuthorDate: Mon Jul 5 18:09:02 2021 +0200
[STREAMPIPES-394] Fix wrong timestamp extractionin Influx sink
---
.../apache/streampipes/sinks/databases/jvm/influxdb/InfluxDbClient.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/influxdb/InfluxDbClient.java
b/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/influxdb/InfluxDbClient.java
index b0e8730..d2da1dc 100644
---
a/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/influxdb/InfluxDbClient.java
+++
b/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/influxdb/InfluxDbClient.java
@@ -64,7 +64,7 @@ public class InfluxDbClient {
this.measureName = measureName;
this.user = user;
this.password = password;
- this.timestampField = InfluxDb.prepareString(timestampField);
+ this.timestampField = timestampField;
this.batchSize = batchSize;
this.flushDuration = flushDuration;
this.logger = logger;