[hotfix] fixed bug in siddhi trend test
@@ -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");
