[
https://issues.apache.org/jira/browse/FLINK-6350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15978586#comment-15978586
]
Stephan Ewen commented on FLINK-6350:
-------------------------------------
This is expected, it is part of the unified batch/streaming abstraction: If you
give the job a finite input, it finishes when the finite input is done.
To simulate unbounded input, use an iterator source or something that resembles
an unbounded input.
> Flink: Windowing does not work with streams from collections and the local
> execution environment
> ------------------------------------------------------------------------------------------------
>
> Key: FLINK-6350
> URL: https://issues.apache.org/jira/browse/FLINK-6350
> Project: Flink
> Issue Type: Bug
> Components: Streaming
> Affects Versions: 1.2.0
> Reporter: Bowen Li
> Assignee: Bowen Li
> Fix For: 1.2.2
>
>
> When using events via the {{fromCollection}} method of
> {{StreamExecutionEnvironment}}, window timing is not supported. The time
> windows close immediately.
> This is unfortunate because mocking events from collections and testing them
> locally is a powerful way to unit test stream processors.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
