【发布时间】：2017-07-14 15:58:44
【问题描述】：
Apache Flink 检查点功能是否需要与有状态函数一起使用？
【问题讨论】：
标签： apache-flink flink-streaming
【发布时间】：2017-07-14 15:58:44
【问题描述】：
你不需要。如果您的函数没有状态，则不会设置任何检查点。但请注意，某些内置函数有自己的状态，例如FlinkKafkaConsumer.
【讨论】：
-
但是如果我有一个流...... something.map,flatmap.map... 这是否意味着我已经计算的所有东西都被处理掉了？还是在检查点保存？
-
如果它没有存储在某个
Sink中，那么是的，这些计算将被释放，并且流将从通过整个 DAG 的最后一个元素重放。