[
https://issues.apache.org/jira/browse/FLINK-18413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng updated FLINK-18413:
--------------------------------
Component/s: (was: Table SQL / API)
API / DataStream
> CollectResultIterator should throw exception if user does not enable
> checkpointing in streaming mode
> ----------------------------------------------------------------------------------------------------
>
> Key: FLINK-18413
> URL: https://issues.apache.org/jira/browse/FLINK-18413
> Project: Flink
> Issue Type: Improvement
> Components: API / DataStream
> Affects Versions: 1.11.0
> Reporter: Caizhi Weng
> Priority: Major
> Fix For: 1.11.0
>
>
> Currently the iterator returned by {{TableResult.collect}} 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.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
