This is an automated email from the ASF dual-hosted git repository.

riemer pushed a commit to branch rel/0.68.0
in repository 
https://gitbox.apache.org/repos/asf/incubator-streampipes-extensions.git


The following commit(s) were added to refs/heads/rel/0.68.0 by this push:
     new a41dd9b  [STREAMPIPES-394] Fix wrong timestamp extractionin Influx sink
a41dd9b is described below

commit a41dd9bbb57302cf9a96016d8b8a1f28e97ebbf5
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