[incubator-streampipes-extensions] branch rel/0.67.0 updated: [hotfix] fixed bug in siddhi trend test

[wi...@apache.org]

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

wiener pushed a commit to branch rel/0.67.0
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes-extensions.git


The following commit(s) were added to refs/heads/rel/0.67.0 by this push:
     new 4c5c2ec  [hotfix] fixed bug in siddhi trend test
4c5c2ec is described below

commit 4c5c2ec1b366c9680dda8d2722d184b071be7718
Author: Patrick Wiener <wi...@fzi.de>
AuthorDate: Wed Sep 9 08:43:30 2020 +0200

    [hotfix] fixed bug in siddhi trend test
---
 .../streampipes/processors/siddhi/trend/TestTrendProcessor.java     | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/streampipes-processors-filters-siddhi/src/test/java/org/apache/streampipes/processors/siddhi/trend/TestTrendProcessor.java b/streampipes-processors-filters-siddhi/src/test/java/org/apache/streampipes/processors/siddhi/trend/TestTrendProcessor.java
index 2dc2c4d..81cd619 100644
--- a/streampipes-processors-filters-siddhi/src/test/java/org/apache/streampipes/processors/siddhi/trend/TestTrendProcessor.java
+++ b/streampipes-processors-filters-siddhi/src/test/java/org/apache/streampipes/processors/siddhi/trend/TestTrendProcessor.java
@@ -19,6 +19,7 @@ package org.apache.streampipes.processors.siddhi.trend;
 
 import static org.junit.Assert.assertEquals;
 
+import org.apache.streampipes.model.util.SchemaUtils;
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.junit.runners.Parameterized;
@@ -100,11 +101,16 @@ public class TestTrendProcessor {
     final Integer[] actualMatchCount = {0};
     DataProcessorDescription originalGraph = new TrendController().declareModel();
     originalGraph.setSupportedGrounding(EventGroundingGenerator.makeDummyGrounding());
+
     DataProcessorInvocation graph =
             InvocationGraphGenerator.makeEmptyInvocation(originalGraph);
+
     graph.setInputStreams(Collections
             .singletonList(EventStreamGenerator
                     .makeStreamWithProperties(Collections.singletonList("randomValue"))));
+
+    graph.setOutputStream(EventStreamGenerator.makeStreamWithProperties(Collections.singletonList("randomValue")));
+
     graph.getOutputStream().getEventGrounding().getTransportProtocol().getTopicDefinition().setActualTopicName("output-topic");
     TrendParameters params = new TrendParameters(graph, trendOperator, increase, timeWindow, "s0" +
             "::randomValue");