0

我已经开发了一个带有检查点和容错功能的 Spark Streaming 应用程序(它也有内部状态)。当我退出我的应用程序并重新运行它时,它正在工作......所以每件事(状态......)都会加载出色地,

我想知道为什么在集群未命中的情况下,它应该工作还是不工作?因为我猜 Spark 将检查点保存为指向内存位置的指针......

4

1 回答 1

0

是的,它应该可以工作,因为集群后,状态会恢复。

于 2016-09-02T12:31:23.353 回答