Apache Flink on Yarn - точка сохранения

Question

Мы используем пряжу на emr для отправки работы flink (flink 1.8.0). Как мы выполняем sh изящное завершение работы с точкой сохранения. Команда останова не распознает -s или -p

Answer 1

Flink 1.8 не поддерживает плавную остановку с точкой сохранения. Эта функция была добавлена ​​в Flink 1.9. С 1.8 вы можете сделать

./bin/flink cancel -s [targetDirectory] <jobID>

См. Документацию CLI для версии 1.8 для получения дополнительной информации.