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)
