Flink故障恢复:如果无状态操作员失败怎么办

问题描述

我们知道,Flink会定期为每个有状态操作员创建检查点,并且当发生崩溃时,它可以使用检查点来恢复系统。但是在这些过程中,我找不到任何有关无状态运算符的文件或文档-“创建检查点”和“故障恢复”。感谢您的帮助。

解决方法

无状态运算符没有状态,因此没有要检查的点或恢复的任何内容,因此这就是为什么在创建或恢复检查点的情况下不讨论它们的原因。

相关问答

Selenium Web驱动程序和Java。元素在(x,y)点处不可单击。其...
Python-如何使用点“。” 访问字典成员?
Java 字符串是不可变的。到底是什么意思?
Java中的“ final”关键字如何工作?(我仍然可以修改对象。...
“loop:”在Java代码中。这是什么,为什么要编译?
java.lang.ClassNotFoundException:sun.jdbc.odbc.JdbcOdbc...