[FLINK-18413] CollectResultIterator should throw exception if user does not enable checkpointing in streaming mode

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Won't Fix
• Affects Version/s: 1.11.0
• Fix Version/s: 1.11.0
• Component/s: API / DataStream
• Labels: pull-request-available
• Assignee: Unassigned
• Reporter: Caizhi Weng
• Created: 23/Jun/20 04:44
• Updated: 23/Jun/20 11:35
• Resolved: 23/Jun/20 11:34

Description

Currently CollectResultIterator will only output results after a checkpoint in streaming mode. It will be strange for users who does not enable checkpointing to stuck forever when using the iterator without further notice.

As 1.11 is about to release, we shall at least throw an exception notifying the user to enable checkpointing. We'll support iterators with at least once semantics or exactly once semantics without fault tolerance in the future.

Issue Links

• links to: GitHub Pull Request #12750