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;

Reply via email to