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

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

Github user aljoscha commented on a diff in the pull request:

    https://github.com/apache/flink/pull/4702#discussion_r140528890
  
    --- Diff: 
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/AccumulatingKeyedTimePanes.java
 ---
    @@ -212,6 +213,11 @@ public KeyedStateStore windowState() {
                public KeyedStateStore globalState() {
                        return globalState;
                }
    +
    +           @Override
    +           public <X> void output(OutputTag<X> outputTag, X value) {
    +                   throw new UnsupportedOperationException("current 
watermark is not supported in this context");
    --- End diff --
    
    Still has the old message about watermarks.


> 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
(v6.4.14#64029)

Reply via email to