Caizhi Weng created FLINK-18413:
-----------------------------------
Summary: TableResult.collect 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
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)