[STREAMPIPES-283] NullPointer Exception in Flink pattern detection processor

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 0.67.0
• Fix Version/s: 1.0.0
• Component/s: Pipeline Elements
• Assignee: Unassigned
• Reporter: Patrick Wiener
• Created: 19/Jan/21 19:50
• Updated: 26/Nov/22 13:44

Description

There is a bug in the Sequence pattern detection processing for Flink currently leading to a Nullpointer Exception in this method:

@Override
public void processElement1(Event value, Context ctx, Collector<Event> out) throws Exception {
 state.update(new EventStorage(System.currentTimeMillis(), value));
}

See error log:

pipeline-elements-all-flink_1  | Caused by: java.lang.NullPointerException
pipeline-elements-all-flink_1  | 	at org.apache.streampipes.processors.pattern.detection.flink.processor.sequence.Sequence.processElement1(Sequence.java:48)
pipeline-elements-all-flink_1  | 	at org.apache.streampipes.processors.pattern.detection.flink.processor.sequence.Sequence.processElement1(Sequence.java:26)
pipeline-elements-all-flink_1  | 	at org.apache.flink.streaming.api.operators.co.LegacyKeyedCoProcessOperator.processElement1(LegacyKeyedCoProcessOperator.java:81)
pipeline-elements-all-flink_1  | 	at org.apache.flink.streaming.runtime.io.StreamTwoInputProcessor.processInput(StreamTwoInputProcessor.java:259)
pipeline-elements-all-flink_1  | 	at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:279)
pipeline-elements-all-flink_1  | 	at org.apache.flink.streaming.runtime.tasks.StreamTask.run(StreamTask.java:301)
pipeline-elements-all-flink_1  | 	at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:406)
pipeline-elements-all-flink_1  | 	at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:705)
pipeline-elements-all-flink_1  | 	at org.apache.flink.runtime.taskmanager.Task.run(Task.java:530)
pipeline-elements-all-flink_1  | 	at java.lang.Thread.run(Unknown Source)