Flink TaskManager через NAT - PullRequest
Новая
       6

Flink TaskManager через NAT

0 голосов
/ 26 января 2020

Я пытаюсь запустить кластер Flink через NAT, где объявленные порты будут отличаться от портов привязки.

Есть ли какая-либо поддержка для этого в Flink?

Я просмотрел конфигурацию и исходный код, но не заметил ничего намекающего на поддержку NAT. Если нет, каков рекомендуемый способ достижения этого?

Заранее спасибо!

1 Ответ

1 голос
/ 03 февраля 2020

Должно быть возможно подключиться к компоненту Flink через NAT.

Если компонентом за NAT является JobManager, то вам необходимо настроить jobmanager.rpc.address и jobmanager.rpc.port со значениями вашего логического имени и порта, через которые JobManager доступен из внешней сети. .

Если компонентом за NAT является TaskManager, то вам необходимо настроить taskmanager.host и taskmanager.rpc.port со значениями вашего логического имени и порта, через которые TaskManager доступен извне сеть.

Обновление

В настоящее время невозможно выполнить Flink через NAT из-за FLINK-15911 . Проблема в том, что Flink не предлагает отдельную конфигурацию связывания и внешнего порта и что TaskManager пытается разрешить taskmanager.host, что не всегда возможно.

...