Отправьте задание Flink на кластер пряжи, чтобы восстановить его состояние с последней точки сохранения

Question

Я выполняю эти задания Flink в кластере пряжи.Когда задание Flink не удается или я перезапускаю его, я хочу, чтобы задание Flink использовало точку сохранения, созданную до ее перезапуска.Как можно перезапустить задание Flink с этой точкой сохранения.Я использую Flink 1.4.2.

Answer 1

Для возобновления из точки сохранения вам нужно позвонить bin/flink run -s :savepointPath [:runArgs], где runArgs содержит банку задания.