[
https://issues.apache.org/jira/browse/FLINK-18413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng updated FLINK-18413:
--------------------------------
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.
was:
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.
> 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 {{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.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
