diff --git a/abstraction/src/main/java/org/streamreasoning/rsp4j/abstraction/ContinuousProgram.java b/abstraction/src/main/java/org/streamreasoning/rsp4j/abstraction/ContinuousProgram.java index 88eab4d3..2dc462d7 100644 --- a/abstraction/src/main/java/org/streamreasoning/rsp4j/abstraction/ContinuousProgram.java +++ b/abstraction/src/main/java/org/streamreasoning/rsp4j/abstraction/ContinuousProgram.java @@ -102,7 +102,7 @@ public void update(Observable o, Object arg) { if (task.getAggregations().isEmpty()) { Stream r2rResult = eval(now); Stream output = r2s.getR2sOperator().eval(r2rResult, now); - output.forEach(out->{System.out.println(out);outputStream.put(out,now);}); + output.forEach(out->{outputStream.put(out,now);}); } else { handleAggregations(task, r2s, now); }