0

我有火花流作业，它开始因 FileNotFound 异常而失败

因为 1.Sparkstreaming 与 maxFilesPerTrigger 一起运行，这导致创建大量未处理的文件积压 2.来自积压的文件已被清理和压缩 3.当作业运行时，它会尝试从上次离开的位置恢复（检查点已尚未处理的文件列表{这些文件现在是 vacummed&compacted}) 4.job 由于上述第 3 点而因 FileNotFound 异常而失败

我如何克服这个问题并在它停止的地方恢复加载表单。

谢谢，拉胡尔

4

0 回答 0