[jira] [Created] (FLINK-12044) Flink CEP discards events as late if they have timestamps <= 0

[Arseniy Tashoyan (JIRA)]

Arseniy Tashoyan created FLINK-12044:
----------------------------------------

             Summary: Flink CEP discards events as late if they have timestamps 
<= 0
                 Key: FLINK-12044
                 URL: https://issues.apache.org/jira/browse/FLINK-12044
             Project: Flink
          Issue Type: Bug
          Components: Library / CEP
    Affects Versions: 1.7.2
            Reporter: Arseniy Tashoyan


Let's make an input stream like this:

{code:scala}
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime)
val events = env.fromElements(
      Event(timestamp = 0L, siteId),
      Event(timestamp = 500L, siteId)
)
.assignTimestampsAndWatermarks(new BoundedOutOfOrdernessTimestampExtractor{...})
{code}

For this stream the event with timestamp = 0L will be treated as late. The 
reason is AbstractKeyedCEPPatternOperator that initializes lastWatermark with 
the default value provided by the compiler: zero. Would it be more correct to 
initialize lastWatermark with Long.MIN_VALUE?

Of course, this is not a blocking defect, but I had really hard times to find 
why my unit test disregards the first event. Strictly speaking, this behavior 
seems incorrect.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)