Установите режим отсоединения Flink с помощью Java

Сведения о кластере Flink,
Количество узлов: 4
Версия Flink: 1.11
Клиент Flink: RestCluserClient

Мы отправляем пакетное задание Flink из потокового задания с помощью PackagedProgram, но наше требование состоит в том, чтобы выполнять только одно задание за раз, допустим, мы получили 2 события из источника, поэтому в идеале должны запускаться два пакетных задания (каждое для каждого события), но только одно в время. Для этого мы использовали client.setDetached (false) (в предыдущей версии flink), но как только мы перевели его на 1.11, setDetached (false) API был удален.

Есть ли у нас идеи, как реализовать это требование?


apache-flink flink-streaming flink-batch
person Murtaza Zaveri    schedule 22.09.2020    source источник

Ответы (1)


arrow_upward
0
arrow_downward

После более подробного анализа я нашел решение. Flink 1.11 API предоставил класс Utils для отправки задания, а именно ClientUtils, и у него есть два метода:

  1. ClientUtils.submitJob () - ›этот метод работает с отключенным режимом как true
  2. ClientUtils.submitJobAndWaitForExecutionResult () - ›это работает как отключенный режим как false.
person Murtaza Zaveri    schedule 24.09.2020