GitHub user Aitozi opened a pull request:
https://github.com/apache/flink/pull/6104
[FLINK-9476]Emit late elements in CEP as sideOutPut
Now, when use with Eventtime in CEP library, elements come later than
watermark will be dropped,we can put it in side Output with outPutTag
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/Aitozi/flink FLINK-9476
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/6104.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 #6104
----
commit c0b04fadacd3e9f3f403b3adfdbadf8d4aac79e4
Author: minwenjun <minwenjun@...>
Date: 2018-05-30T15:32:15Z
Add loseDataOutputTag in cep deal with event time dropped data
commit 373e376fc182c32fe69765aa564e93057954ff44
Author: minwenjun <minwenjun@...>
Date: 2018-05-30T15:50:01Z
add scala api
----
---
