[incubator-streampipes-extensions] branch dev updated: [hotfix] Fix error in data lake when runtime name contained capital letters

[ze...@apache.org]

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

zehnder 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 4ee2eed  [hotfix] Fix error in data lake when runtime name contained capital letters
4ee2eed is described below

commit 4ee2eede17acacd1aa96897ddb45dba1240d02d0
Author: Philipp Zehnder <ze...@fzi.de>
AuthorDate: Mon Aug 30 22:12:08 2021 +0200

    [hotfix] Fix error in data lake when runtime name contained capital letters
---
 .../org/apache/streampipes/sinks/internal/jvm/datalake/DataLake.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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 332edf0..2fc6163 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
@@ -77,7 +77,8 @@ public class DataLake implements EventSink<DataLakeParameters> {
 
     EventSchema schema = runtimeContext.getInputSchemaInfo().get(0).getEventSchema();
 
-    this.eventSchema = schema;
+    // deep copy of event schema. Event property runtime name is changed to lower case for the schema registration
+    this.eventSchema = new EventSchema(schema);
 
     schema.getEventProperties().stream().forEach(eventProperty -> {
       eventProperty.setRuntimeName(prepareString(eventProperty.getRuntimeName()));