[FLINK-3682] CEP operator does not set the processing timestamp correctly

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.0.0
• Fix Version/s: 1.0.1, 1.1.0
• Component/s: Library / CEP
• Assignee: Till Rohrmann
• Reporter: Till Rohrmann
• Created: 30/Mar/16 13:27
• Updated: 31/Mar/16 08:33
• Resolved: 31/Mar/16 08:33

Description

In the wake of reworking the timestamp assignment where the processing timestamp has to be set now by the StreamOperator, the CEP operators have not been adapted. This causes that the timestamp value assigned to the StreamRecord is used. In case of processing time this is Long.MIN_VALUE. In combination with a CEP time window, this can lead to an underflow in the NFA where the window time is subtracted from the current timestamp value.