You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by bo...@apache.org on 2021/03/19 13:34:09 UTC

[incubator-streampipes-extensions] 01/02: [STREAMPIPES-315] fix issue

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

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

commit 56f4c1439f881221e867d6b1cd2b48b035d097d1
Author: bossenti <bo...@posteo.de>
AuthorDate: Wed Mar 17 13:12:40 2021 +0100

    [STREAMPIPES-315] fix issue
---
 .../jvm/processor/state/labeler/model/StatementUtils.java             | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/state/labeler/model/StatementUtils.java b/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/state/labeler/model/StatementUtils.java
index 32b86d6..3e01c96 100644
--- a/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/state/labeler/model/StatementUtils.java
+++ b/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/state/labeler/model/StatementUtils.java
@@ -128,10 +128,10 @@ public class StatementUtils {
             return calculatedValue <= statement.getValue();
         } else if ("<".equals(statement.getOperator())) {
             return calculatedValue < statement.getValue();
-        } else if ("=".equals(statement.getOperator())) {
+        } else if ("==".equals(statement.getOperator())) {
             return calculatedValue == statement.getValue();
         } else {
-            return true;
+            return false;
         }
     }