You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ri...@apache.org on 2020/10/29 19:51:47 UTC

[incubator-streampipes] branch dev updated: [hotfix] Consider alternatives for mapping property calculation

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 <ri...@fzi.de>
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);