[streampipes] branch SP-1504 created (now c94bdc62a)

[ze...@apache.org]

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

zehnder pushed a change to branch SP-1504
in repository https://gitbox.apache.org/repos/asf/streampipes.git


      at c94bdc62a [SP-1504] Do not remove streams on pipeline export

This branch includes the following new commits:

     new c94bdc62a [SP-1504] Do not remove streams on pipeline export

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.

[streampipes] 01/01: [SP-1504] Do not remove streams on pipeline export

[ze...@apache.org]

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

zehnder pushed a commit to branch SP-1504
in repository https://gitbox.apache.org/repos/asf/streampipes.git

commit c94bdc62a7c27271a55f0474cd9f871fdfea9ce3
Author: Philipp Zehnder <te...@users.noreply.github.com>
AuthorDate: Wed Apr 12 17:11:41 2023 +0200

    [SP-1504] Do not remove streams on pipeline export
---
 .../java/org/apache/streampipes/export/resolver/PipelineResolver.java   | 2 --
 1 file changed, 2 deletions(-)

diff --git a/streampipes-data-export/src/main/java/org/apache/streampipes/export/resolver/PipelineResolver.java b/streampipes-data-export/src/main/java/org/apache/streampipes/export/resolver/PipelineResolver.java
index 9ba922136..bd71f676d 100644
--- a/streampipes-data-export/src/main/java/org/apache/streampipes/export/resolver/PipelineResolver.java
+++ b/streampipes-data-export/src/main/java/org/apache/streampipes/export/resolver/PipelineResolver.java
@@ -19,7 +19,6 @@
 package org.apache.streampipes.export.resolver;
 
 import org.apache.streampipes.export.utils.SerializationUtils;
-import org.apache.streampipes.model.SpDataSet;
 import org.apache.streampipes.model.export.ExportItem;
 import org.apache.streampipes.model.pipeline.Pipeline;
 
@@ -43,7 +42,6 @@ public class PipelineResolver extends AbstractResolver<Pipeline> {
     doc.setActions(doc.getActions().stream().peek(s -> s.setSelectedEndpointUrl(null)).collect(Collectors.toList()));
     doc.setStreams(doc.getStreams()
         .stream()
-        .filter(s -> s instanceof SpDataSet).peek(s -> ((SpDataSet) s).setSelectedEndpointUrl(null))
         .collect(Collectors.toList()));
     return doc;
   }