我已经开发了一个带有检查点和容错功能的 Spark Streaming 应用程序(它也有内部状态)。当我退出我的应用程序并重新运行它时,它正在工作......所以每件事(状态......)都会加载出色地,
我想知道为什么在集群未命中的情况下,它应该工作还是不工作?因为我猜 Spark 将检查点保存为指向内存位置的指针......
我已经开发了一个带有检查点和容错功能的 Spark Streaming 应用程序(它也有内部状态)。当我退出我的应用程序并重新运行它时,它正在工作......所以每件事(状态......)都会加载出色地,
我想知道为什么在集群未命中的情况下,它应该工作还是不工作?因为我猜 Spark 将检查点保存为指向内存位置的指针......