[incubator-streampipes] branch STREAMPIPES-545 updated: [hotfix] Update data explorer writer

[ze...@apache.org]

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

zehnder pushed a commit to branch STREAMPIPES-545
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git


The following commit(s) were added to refs/heads/STREAMPIPES-545 by this push:
     new f39a99ec5 [hotfix] Update data explorer writer
f39a99ec5 is described below

commit f39a99ec554b82508c49741ad7e236617e8ce442
Author: Philipp Zehnder <ze...@fzi.de>
AuthorDate: Mon Jul 25 21:46:39 2022 +0200

    [hotfix] Update data explorer writer
---
 .../apache/streampipes/dataexplorer/commons/DataExplorerWriter.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/streampipes-data-explorer-commons/src/main/java/org/apache/streampipes/dataexplorer/commons/DataExplorerWriter.java b/streampipes-data-explorer-commons/src/main/java/org/apache/streampipes/dataexplorer/commons/DataExplorerWriter.java
index a9b6b987c..3f3a1edc6 100644
--- a/streampipes-data-explorer-commons/src/main/java/org/apache/streampipes/dataexplorer/commons/DataExplorerWriter.java
+++ b/streampipes-data-explorer-commons/src/main/java/org/apache/streampipes/dataexplorer/commons/DataExplorerWriter.java
@@ -13,8 +13,9 @@ public class DataExplorerWriter {
 
     // TODO return a connection here
     public void connect(DataExplorerConnectionSettings dataExplorerConnectionSettings) {
-        this.influxDB = InfluxDBFactory.connect(dataExplorerConnectionSettings.getInfluxDbHost(),
+        this.influxDB = InfluxDBFactory.connect(dataExplorerConnectionSettings.getInfluxDbHost() + ":" + dataExplorerConnectionSettings.getInfluxDbPort(),
                 dataExplorerConnectionSettings.getUser(), dataExplorerConnectionSettings.getPassword());
+        this.influxDB.setDatabase(DataExplorerDefaults.DATA_LAKE_DATABASE_NAME);
     }
 
     public void close() {
@@ -38,7 +39,6 @@ public class DataExplorerWriter {
             }
         }
 
-        this.influxDB.setDatabase(DataExplorerDefaults.DATA_LAKE_DATABASE_NAME);
         this.influxDB.write(builder.build());
     }