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

riemer pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/streampipes.git


The following commit(s) were added to refs/heads/dev by this push:
     new 7cc4e0209 Improve Log info in Processor Test (#1445)
7cc4e0209 is described below

commit 7cc4e0209c00d8b1c02cf4d7943e36e2fa09426c
Author: Liu Xiao <[email protected]>
AuthorDate: Fri Mar 24 18:04:15 2023 +0800

    Improve Log info in Processor Test (#1445)
---
 .../processor/booloperator/counter/TestBooleanCounterProcessor.java   | 4 ++--
 .../processor/booloperator/inverter/TestBooleanInverterProcessor.java | 4 ++--
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/counter/TestBooleanCounterProcessor.java
 
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/counter/TestBooleanCounterProcessor.java
index 55fc52996..a97da99ca 100644
--- 
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/counter/TestBooleanCounterProcessor.java
+++ 
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/counter/TestBooleanCounterProcessor.java
@@ -135,12 +135,12 @@ public class TestBooleanCounterProcessor {
     assertEquals(expectedBooleanCount, counter);
   }
 
-
   private Integer sendEvents(BooleanCounterProcessor booleanCounter, 
SpOutputCollector spOut) {
     int counter = 0;
     List<Event> events = makeEvents();
     for (Event event : events) {
-      LOG.info("Sending event with value " + event.getFieldBySelector("s0::" + 
invertFieldName));
+      LOG.info("Sending event with value "
+          + event.getFieldBySelector("s0::" + 
invertFieldName).getAsPrimitive().getAsBoolean());
       booleanCounter.onEvent(event, spOut);
       try {
         Thread.sleep(100);
diff --git 
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/inverter/TestBooleanInverterProcessor.java
 
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/inverter/TestBooleanInverterProcessor.java
index 2a46a4308..e753903a8 100644
--- 
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/inverter/TestBooleanInverterProcessor.java
+++ 
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/inverter/TestBooleanInverterProcessor.java
@@ -124,12 +124,12 @@ public class TestBooleanInverterProcessor {
     assertEquals(expectedBooleanCount, result);
   }
 
-
   private boolean sendEvents(BooleanInverterProcessor trend, SpOutputCollector 
spOut) {
     boolean result = false;
     List<Event> events = makeEvents();
     for (Event event : events) {
-      LOG.info("Sending event with value " + event.getFieldBySelector("s0::" + 
invertFieldName));
+      LOG.info("Sending event with value "
+          + event.getFieldBySelector("s0::" + 
invertFieldName).getAsPrimitive().getAsBoolean());
       trend.onEvent(event, spOut);
       try {
         Thread.sleep(100);

Reply via email to