[incubator-streampipes-extensions] 01/02: fix configuration description, change image path route description

[te...@apache.org]

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

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

commit fb2aa3af2bbf4666f183c77e9c032e24bb0bc4d7
Author: tex <te...@fzi.de>
AuthorDate: Wed Apr 15 19:06:26 2020 +0200

    fix configuration description, change image path route description
---
 .../streampipes/sinks/internal/jvm/config/SinksInternalJvmConfig.java   | 2 +-
 .../org/apache/streampipes/sinks/internal/jvm/datalake/DataLake.java    | 2 ++
 2 files changed, 3 insertions(+), 1 deletion(-)

diff --git a/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/config/SinksInternalJvmConfig.java b/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/config/SinksInternalJvmConfig.java
index b7bab31..36c13f7 100644
--- a/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/config/SinksInternalJvmConfig.java
+++ b/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/config/SinksInternalJvmConfig.java
@@ -55,7 +55,7 @@ public enum SinksInternalJvmConfig implements PeConfig {
 		config.register(ConfigKeys.BACKEND_HOST, "backend", "Hostname for the StreamPipes-Backend");
 		config.register(ConfigKeys.BACKEND_PORT, 8030, "Port for the StreamPipes-Backend");
 		config.register(ConfigKeys.BACKEND_PROTOCOL, "http", "Protocol for the StreamPipes-Backend");
-		config.register(ConfigKeys.IMAGE_STORAGE_LOCATION, "/sp_images/", "Protocol for the StreamPipes-Backend");
+		config.register(ConfigKeys.IMAGE_STORAGE_LOCATION, "/sp_images/", "Storage location of the data lake images");
 
 
 		config.register(ConfigKeys.SERVICE_NAME, service_name, "The name of the service");
diff --git a/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/datalake/DataLake.java b/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/datalake/DataLake.java
index a3254eb..aa1c2e3 100644
--- a/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/datalake/DataLake.java
+++ b/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/datalake/DataLake.java
@@ -98,6 +98,8 @@ public class DataLake implements EventSink<DataLakeParameters> {
         String image = event.getFieldByRuntimeName(eventProperty.getRuntimeName()).getAsPrimitive().getAsString();
 
         this.writeToImageFile(image, fileRoute);
+        fileRoute = fileRoute.replace("/", "_");
+        fileRoute = fileRoute.replace("." , "_");
         event.updateFieldBySelector("s0::" + eventProperty.getRuntimeName(), fileRoute);
       });