GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/1841
[FLINK-3682] [cep] Assign processing timestamp in CEP operators
This PR fixes the problem that the CEP operators did not assign the wall
clock time
as the timestamp to incoming in StreamRecords if the TimeCharacteristic was
set to
ProcessingTime. Processing element with a Long.MIN_VALUE timestamp can lead
to underflows
in the NFA if a positive window length is subtracted from the timestamp.
For this
underflow a sanity check has been added to notify the user with an
exception about it.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/tillrohrmann/flink fixUnderflowPruning
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/1841.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #1841
----
commit 3adc65e0d65604b6255f792f00a76ec017170f0d
Author: Till Rohrmann <[email protected]>
Date: 2016-03-30T13:27:21Z
[FLINK-3682] [cep] Assign processing timestamp in CEP operators
This PR fixes the problem that the CEP operators did not assign the wall
clock time
as the timestamp to incoming in StreamRecords if the TimeCharacteristic was
set to
ProcessingTime. Processing element with a Long.MIN_VALUE timestamp can lead
to underflows
in the NFA if a positive window length is subtracted from the timestamp.
For this
underflow a sanity check has been added to notify the user with an
exception about it.
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
