From aed1514c0b73bd0e00e11e7de6b4fa65842935e2 Mon Sep 17 00:00:00 2001
From: DomWos <blind.van@gmail.com>
Date: Mon, 22 Oct 2018 11:54:39 +0200
Subject: [PATCH] Filtering fix.

---
 .../src/main/java/com/baeldung/storm/bolt/FilteringBolt.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/libraries-data/src/main/java/com/baeldung/storm/bolt/FilteringBolt.java b/libraries-data/src/main/java/com/baeldung/storm/bolt/FilteringBolt.java
index a2e80deb33..564076a1df 100644
--- a/libraries-data/src/main/java/com/baeldung/storm/bolt/FilteringBolt.java
+++ b/libraries-data/src/main/java/com/baeldung/storm/bolt/FilteringBolt.java
@@ -10,7 +10,7 @@ public class FilteringBolt extends BaseBasicBolt {
     @Override
     public void execute(Tuple tuple, BasicOutputCollector basicOutputCollector) {
         int operation = tuple.getIntegerByField("operation");
-        if(operation >= 0 ) {
+        if(operation > 0 ) {
             basicOutputCollector.emit(tuple.getValues());
         }
     }