Что такое автономный режим Apache Flink?

Question

Я видел эту строку в документации Flink , но не могу понять, что означает «режим отсоединения». Пожалуйста помоги. Спасибо.

Запуск примера программы в отдельном режиме:

./bin/flink run -d ./examples/batch/WordCount.jar

Answer 1

Flink CLI запускает задания либо в режиме блокировки, либо в автономном режиме. В режиме блокировки процесс CliFrontend (клиент) продолжает работать, заблокирован, ожидая завершения задания, после чего выводит некоторую информацию. В приведенном ниже примере я запустил потоковое задание, которое через несколько секунд отменил в WebUI:

$ flink run target/oscon-1.0-SNAPSHOT.jar 
Starting execution of program
Program execution finished
Job with JobID b02da01c30585bfbc86a23446559987f has finished.
Job Runtime: 8673 ms

Если вы работаете в режиме блокировки, вы можете при желании убить CliFrontend (например, с помощью ctrl-C), и задание не будет затронуто, если оно выполняется достаточно далеко, чтобы отправить задание в кластер. ,

В автономном режиме CliFrontend отправляет задание в кластер и сразу же завершает работу.

Answer 2

Это означает, что приложение не присоединено (или не привязано) к вашему сеансу оболочки.Таким образом, если вы закроете свой терминал, приложение все равно продолжит работу (пока не завершит свою работу).Для пакетного примера это не может быть большой проблемой - они обработают данный пакет данных и завершат его впоследствии.Как только вы перейдете к потоковому подходу, операции будут выполняться с «бесконечным потоком данных» и не имеют определенного конца.

Надеюсь, это поможет.