[
https://issues.apache.org/jira/browse/FLINK-18413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng updated FLINK-18413:
--------------------------------
Summary: CollectResultIterator should throw exception if user does not
enable checkpointing in streaming mode (was: TableResult.collect should throw
exception if user does not enable checkpointing in streaming mode)
> 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: Table SQL / API
> 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)
