[jira] [Commented] (FLINK-9476) Lost sideOutPut Late Elements in CEP Operator

["ASF GitHub Bot (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/FLINK-9476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495355#comment-16495355 ] 

ASF GitHub Bot commented on FLINK-9476:
---------------------------------------

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 <mi...@...>
Date:   2018-05-30T15:32:15Z

    Add loseDataOutputTag in cep deal with event time dropped data

commit 373e376fc182c32fe69765aa564e93057954ff44
Author: minwenjun <mi...@...>
Date:   2018-05-30T15:50:01Z

    add scala api

----


> Lost sideOutPut Late Elements in CEP Operator
> ---------------------------------------------
>
>                 Key: FLINK-9476
>                 URL: https://issues.apache.org/jira/browse/FLINK-9476
>             Project: Flink
>          Issue Type: Improvement
>          Components: CEP
>    Affects Versions: 1.4.2
>            Reporter: aitozi
>            Assignee: aitozi
>            Priority: Major
>




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