Folks,
У нас есть несколько заданий flink - собранных в виде отдельных исполняемых Jars
Для выполнения каждого из этих заданий flink используется следующее -
> StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
>
> try {
> env.execute("FLINK-JOB");
> } catch (Exception ex) {
> // Some message
> }
Нокогда мы развертываем эти задания Flink (всего 5) - выполняется только одно, а другое закрывается.
способ развертывания - через bin / flink run
Большое спасибо