Skip to content
Snippets Groups Projects
Commit 5dcc45b9 authored by Andrea Burattin's avatar Andrea Burattin
Browse files

Fixed bug with the processor of internal events

parent 1c395c46
No related branches found
No related tags found
No related merge requests found
......@@ -82,7 +82,7 @@ public abstract class StreamMiningAlgorithm<T extends Response> extends RichFlat
protected T process(BEvent event) {
try {
long value = 1;
if (processedEvents.value() != null) {
if (processedEvents == null || processedEvents.value() != null) {
value = processedEvents.value() + 1;
}
processedEvents.update(value);
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment