Я разработал приложение Spark Streaming (которое также имеет внутренние антенны) с проверкой и отказоустойчивостью. Это работает, когда я выхожу из своего приложения и повторно запускаю его ... поэтому все вещи (состояния ..) загружаются хорошо,Контрольная точка при сбоях в искровом узле
Интересно, почему в случае сбоя кластера, должно ли оно работать или нет? потому что я думаю, что контрольные точки Spark сохраняют как указатели на ячейку памяти ...