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

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

Github user aljoscha commented on the pull request:

    https://github.com/apache/flink/pull/1328#issuecomment-153772340
  
    If you add it in `AbstractUdfStreamOperator` then you can remove the 
`setOutputType` in `WindowOperator` and `NonKeyedWindowOperator`.


> Windowed fold operation fails because the initial value was not serialized
> --------------------------------------------------------------------------
>
>                 Key: FLINK-2968
>                 URL: https://issues.apache.org/jira/browse/FLINK-2968
>             Project: Flink
>          Issue Type: Bug
>    Affects Versions: 0.10
>            Reporter: Till Rohrmann
>            Assignee: Till Rohrmann
>
> The windowed fold operation currently fails because the initial value was not 
> serialized. The reason for this is that the fold operation is realized as a 
> {{WindowFunction}} within an {{AbstractUdfStreamOperator}} and does not get 
> the output type information forwarded (which is necessary for the 
> serialization). 
> The solution is to let the {{AbstractUdfStreamOperator}} forward the output 
> type information to the {{WindowFunction}} if it implements the 
> {{OutputTypeConfigurable}} interface.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to