Removes duplicate reported answers

streamreasoning · Dec 10, 2021 · 7d0efb1 · 7d0efb1
1 parent 5910b9b
commit 7d0efb1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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<R> r2rResult = eval(now);
           Stream<O> 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);
         }