[jira] [Created] (FLINK-18413) TableResult.collect should throw exception if user does not enable checkpointing in streaming mode

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-18413) TableResult.collect should throw exception if user does not enable checkpointing in streaming mode

Shang Yuanchun (Jira)
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)