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

riemer pushed a commit to branch 
3097-duplicated-schema-update-properties-in-data-lake-configuration
in repository https://gitbox.apache.org/repos/asf/streampipes.git


The following commit(s) were added to 
refs/heads/3097-duplicated-schema-update-properties-in-data-lake-configuration 
by this push:
     new 0d00308515 fix(#3097): Avoid that pipeline element version gets lost
0d00308515 is described below

commit 0d00308515bca7796b0703060fe6238a7240f43c
Author: Dominik Riemer <[email protected]>
AuthorDate: Sun Aug 4 22:42:42 2024 +0200

    fix(#3097): Avoid that pipeline element version gets lost
---
 .../java/org/apache/streampipes/model/graph/DataProcessorInvocation.java | 1 +
 .../main/java/org/apache/streampipes/model/graph/DataSinkInvocation.java | 1 +
 2 files changed, 2 insertions(+)

diff --git 
a/streampipes-model/src/main/java/org/apache/streampipes/model/graph/DataProcessorInvocation.java
 
b/streampipes-model/src/main/java/org/apache/streampipes/model/graph/DataProcessorInvocation.java
index 23c651074a..4414f2b749 100644
--- 
a/streampipes-model/src/main/java/org/apache/streampipes/model/graph/DataProcessorInvocation.java
+++ 
b/streampipes-model/src/main/java/org/apache/streampipes/model/graph/DataProcessorInvocation.java
@@ -56,6 +56,7 @@ public class DataProcessorInvocation extends 
InvocableStreamPipesEntity implemen
     this.setIncludedAssets(other.getIncludedAssets());
     this.setIncludedLocales(other.getIncludedLocales());
     this.setElementId(ElementIdGenerator.makeElementId(this));
+    this.setVersion(other.getVersion());
     this.serviceTagPrefix = SpServiceTagPrefix.DATA_PROCESSOR;
   }
 
diff --git 
a/streampipes-model/src/main/java/org/apache/streampipes/model/graph/DataSinkInvocation.java
 
b/streampipes-model/src/main/java/org/apache/streampipes/model/graph/DataSinkInvocation.java
index a7df9500fd..bc95f269c9 100644
--- 
a/streampipes-model/src/main/java/org/apache/streampipes/model/graph/DataSinkInvocation.java
+++ 
b/streampipes-model/src/main/java/org/apache/streampipes/model/graph/DataSinkInvocation.java
@@ -53,6 +53,7 @@ public class DataSinkInvocation extends 
InvocableStreamPipesEntity {
     this.setElementId(ElementIdGenerator.makeElementId(this));
     this.setIncludedAssets(other.getIncludedAssets());
     this.setIncludedLocales(other.getIncludedLocales());
+    this.setVersion(other.getVersion());
     this.serviceTagPrefix = SpServiceTagPrefix.DATA_SINK;
   }
 

Reply via email to