[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;
   }