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

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


The following commit(s) were added to refs/heads/dev by this push:
     new f4dcb7d  [hotfix] Consider alternatives for mapping property 
calculation
f4dcb7d is described below

commit f4dcb7d32c235ae669738763124e56ae3381baf3
Author: Dominik Riemer <[email protected]>
AuthorDate: Thu Oct 29 20:51:29 2020 +0100

    [hotfix] Consider alternatives for mapping property calculation
---
 .../streampipes/manager/matching/PipelineVerificationHandler.java      | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/PipelineVerificationHandler.java
 
b/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/PipelineVerificationHandler.java
index ff80bdb..210c8c4 100644
--- 
a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/PipelineVerificationHandler.java
+++ 
b/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/PipelineVerificationHandler.java
@@ -132,6 +132,9 @@ public class PipelineVerificationHandler {
     } else if (property instanceof StaticPropertyGroup) {
       updateStaticProperties(inputStreams, 
property.as(StaticPropertyGroup.class).getStaticProperties());
     } else if (property instanceof StaticPropertyAlternatives) {
+      ((StaticPropertyAlternatives) property)
+              .getAlternatives()
+              .forEach(al -> updateStaticProperty(inputStreams, 
al.getStaticProperty()));
       // TODO
     } else if (property instanceof CollectionStaticProperty) {
       CollectionStaticProperty collection = 
property.as(CollectionStaticProperty.class);

Reply via email to