как восстановить задания flink после перезапуска yarn

#apache-flink

Вопрос:

  1. начните сеанс флинка с ./yarn-session.sh -д
  2. отправьте 10 заданий.
  3. перезапустите yarn вручную, но задания flink не могут восстановиться. Что мне нужно сделать, так это сохранить каждое задание перед перезапуском yarn.

Комментарии:

1. Вы включили и настроили как контрольную точку, так и высокую доступность? Они необходимы для автоматического восстановления. В противном случае вы можете вручную выбрать точку сохранения для каждого задания, а затем вручную перезапустить их.