Я пытаюсь скомпилировать данный SQL в граф работы Флинка и хочу отправить его в YARN.
JobGraph jobGraph = streamExecutionEnv.getStreamGraph (). GetJobGraph ();
YarnDeployer () .deployJob (jobGraph);
YarnDeployer - это пользовательский класс, который использует YarnClusterDescriptor и ClusterSpecification API Flink для отправки задания.
В EMR я запустил сеанс Flink YARN и отправил задание с использованием flink запустить.
Я получаю сообщение об ошибке ниже: программа не содержит задание Flink. Возможно, вы забыли вызвать execute () в среде выполнения.
возможно ли запустить JobGraph без выполнения? Я не хочу работать непрерывно.