У меня есть приложение для потоковой передачи искры, работающее на пряже, которое использует источник jms.У меня есть контрольная точка и WAL включены, чтобы обеспечить нулевую потерю данных.Однако, когда я внезапно убиваю свое приложение и перезапускаю его, иногда оно восстанавливает данные из WAL, но иногда это не так !!Во всех случаях я вижу, что WAL написано правильно на HDFS.
Может кто-нибудь объяснить мне, почему мой WAL иногда игнорируется при перезапуске?Каковы условия для искры, чтобы решить восстановить или нет из WAL?
Спасибо.