Запуск Flink, встроенный в другие программы, относится к режиму локального выполнения Flink . Локальный режим выполнения запускает программу Flink в вашей JVM. Это влечет за собой то, что задание не будет выполняться распределенно.
То, что в настоящее время невозможно из коробки, - это позволить заданиям Flink управлять другими заданиями Flink. Тем не менее, можно создать приложение Flink, которое принимает в качестве входных данных задания и выполняет их. RBEA является примером такого приложения Flink. Концептуальное отличие состоит в том, что у вас нет нескольких заданий Flink, но есть одно, которое обрабатывает программы как входные записи.
В качестве альтернативы вы можете взглянуть на Stateful functions , который является виртуальным актерский каркас, построенный поверх Apache Flink. Идея состоит в том, чтобы обеспечить основу для создания распределенных приложений с отслеживанием состояния с надежными гарантиями согласованности. С помощью функций с сохранением состояния вы также создадите одно приложение Flink, которое обрабатывает события, которые могут представлять форму вычислений.