flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Chen Qin (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-7635) support sideOutput in ProcessWindowFunciton & ProcessAllWindowFunction
Date Tue, 19 Sep 2017 00:03:02 GMT

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

Chen Qin commented on FLINK-7635:

[~phoenixjiangnan] there are good reference in PorcessFunction.Context especially in unit
tests and comments. Also might consider how to surface OutputTag error message to user where
late arriving events conflict with ones from ProcessWindowFunction possible.

> support sideOutput in ProcessWindowFunciton & ProcessAllWindowFunction
> ----------------------------------------------------------------------
>                 Key: FLINK-7635
>                 URL: https://issues.apache.org/jira/browse/FLINK-7635
>             Project: Flink
>          Issue Type: Improvement
>          Components: DataStream API, Scala API
>            Reporter: Chen Qin
>            Assignee: Bowen Li
>            Priority: Minor
>             Fix For: 1.4.0, 1.3.3
> [FLINK-4460|https://issues.apache.org/jira/browse/FLINK-4460] only implemented output
to ProcessFunction Context. It would be nice to add support to ProcessWindow and ProcessAllWindow
functions as well. [email threads|http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/question-on-sideoutput-from-ProcessWindow-function-td15500.html]
> [~aljoscha] I thought this is good warm up task for ppl to learn how window function
works in general. Otherwise feel free to assign back to me.

This message was sent by Atlassian JIRA

View raw message