Как проверить, запущен ли сеанс Flink Yarn?

Question

Как проверить, запущен ли сеанс Flink Yarn в кластере Flink?

В частности, я хочу проверить это программно и запустить сеанс, если он не выполняется в рамках автоматического развертывания.

https://ci.apache.org/projects/flink/flink-docs-stable/ops/cli.html не имеет очевидных команд.

Answer 1

Если он уже запущен, REST API Flink будет прослушивать какой-либо порт. Вы можете использовать что-то вроде curl server:8081, чтобы увидеть, доступно ли оно. Если он не запущен, curl выйдет со статусом 7, чтобы указать, что соединение было отклонено.

Answer 2

Я закончил, используя это:

/usr/bin/yarn application -list 2>/dev/null | grep -i "Flink session" | awk '{print $1}'`