[
https://issues.apache.org/jira/browse/FLINK-3178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15173369#comment-15173369
]
ASF GitHub Bot commented on FLINK-3178:
---------------------------------------
Github user wenlonglwl commented on the pull request:
https://github.com/apache/flink/pull/1542#issuecomment-190586930
@aljoscha @StephanEwen This would not work for finite stream, data of
in-flight window would lost, when the stream finished. Can this clear window
operator changed to be configurable. in our production environment, window is
used to do some aggregation, and no lost of data is acceptable.
> Make Closing Behavior of Window Operators Configurable
> ------------------------------------------------------
>
> Key: FLINK-3178
> URL: https://issues.apache.org/jira/browse/FLINK-3178
> Project: Flink
> Issue Type: Improvement
> Components: Streaming
> Affects Versions: 1.0.0
> Reporter: Aljoscha Krettek
> Assignee: Aljoscha Krettek
> Priority: Blocker
> Fix For: 1.0.0
>
>
> Right now, all window operators emit (incomplete) in-flight windows when they
> are closing down. This happens for two reasons:
> 1. sources emit a final Long.MAX_VALUE watermark to flush out windows when
> they close.
> 2. window operators emit in-flight windows in their close() method
> For some users this might not be the desired behavior so we should either
> change it or make it configurable.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
