[FLINK-6350] Flink: Windowing does not work with streams from collections and the local execution environment

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Not A Problem
• Affects Version/s: 1.2.0
• Fix Version/s: 1.2.2
• Component/s: API / DataStream
• Assignee: Bowen Li
• Reporter: Bowen Li
• Created: 21/Apr/17 02:42
• Updated: 28/Feb/19 11:14
• Resolved: 21/Apr/17 12:03

Description

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.