From ab8da9ffc023a7f48cd2afff1f92ffd8c01c5a14 Mon Sep 17 00:00:00 2001 From: Andrea Burattin <andrea.burattin@gmail.com> Date: Tue, 3 Jan 2023 14:25:18 +0100 Subject: [PATCH] Fixed tricky bug with events counting --- pom.xml | 2 +- .../beamline/models/algorithms/StreamMiningAlgorithm.java | 8 +++++--- 2 files changed, 6 insertions(+), 4 deletions(-) diff --git a/pom.xml b/pom.xml index 37447d5..c3b6bcd 100644 --- a/pom.xml +++ b/pom.xml @@ -3,7 +3,7 @@ <modelVersion>4.0.0</modelVersion> <groupId>beamline</groupId> <artifactId>framework</artifactId> - <version>0.2.2</version> + <version>0.2.3</version> <properties> <maven.compiler.source>11</maven.compiler.source> diff --git a/src/main/java/beamline/models/algorithms/StreamMiningAlgorithm.java b/src/main/java/beamline/models/algorithms/StreamMiningAlgorithm.java index f1d7109..9e016b5 100644 --- a/src/main/java/beamline/models/algorithms/StreamMiningAlgorithm.java +++ b/src/main/java/beamline/models/algorithms/StreamMiningAlgorithm.java @@ -81,9 +81,11 @@ public abstract class StreamMiningAlgorithm<T extends Response> extends RichFlat */ protected T process(BEvent event) { try { - long value = 1; - if (processedEvents != null && processedEvents.value() != null) { - value = processedEvents.value() + 1; + long value = 0; + if (processedEvents != null) { + if (processedEvents.value() != null) { + value = processedEvents.value() + 1; + } processedEvents.update(value); } } catch (IOException e) { -- GitLab