flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Bowen Li (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-7635) Support sideOutput in ProcessWindowFunciton
Date Thu, 21 Sep 2017 05:30:00 GMT

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

Bowen Li commented on FLINK-7635:

[~foxss] [~aljoscha]

After taking a quick look at the code structure, I decided to split the task into two: this
ticket for ProcessWindowFunciton, and FLINK-7660 for ProcessAllWindowFunciton.

I'll work on this ticket first, so I can not only focus on one thing while getting familiar
with the code, but also iterate code and deal with feedbacks faster. After finishing this
ticket, I guess I should be able to complete FLINK-7660 pretty quickly.

> Support sideOutput in ProcessWindowFunciton
> -------------------------------------------
>                 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