У меня есть экземпляр EC2, который находится в us-east-1b и запускает менеджер заданий flink, который отвечает за координацию работы нескольких диспетчеров задач через RPC и сервер истории.Я вижу из netstat, что менеджер по работе слушает :::6123
для входящих соединений диспетчера задач.
У меня есть группа автоматического масштабирования, которая запускает экземпляр EC2 в той же az, подсети и группе безопасности, что и экземпляр EC2.
Группа безопасности разрешает весь трафик на всех портах из любого источника в группе в любой пункт назначения в группе:
Я использую этот ASG в качестве поставщика емкости для задач ECS. Затем я пытаюсь запустить задачу в ECS, которая запускает диспетчер задач и использует этот ASG.
Диспетчер задач запускается, но не подключается к диспетчеру заданий:
2021-09-28 13:52:08,651 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] — не удалось разрешить адрес ResourceManager akka.tcp://[email protected]. внутренний: 6123/user/rpc/resourcemanager_*, повторная попытка через 10000 мс: не удалось подключиться к конечной точке rpc по адресу akka.tcp://[email protected]:6123/user/ rpc/менеджер_ресурсов_*.
Я подключился по ssh-d к экземпляру, запущенному ASG, и подтвердил, что могу свернуть менеджер заданий на ip-xxx-xx-x-xxx.ec2.internal:8081
- оно работает. Итак, я знаю, что экземпляр диспетчера задач может видеть экземпляр диспетчера заданий.
Обобщить:
- Диспетчер задач и диспетчер заданий находятся в одном и том же VPC, в одной зоне доступности, в одной подсети и в одной группе безопасности.
- Группа безопасности разрешает весь входящий трафик из источников в той же группе безопасности.
- Группы безопасности разрешают весь исходящий трафик в любой пункт назначения.
- Диспетчер заданий работает на экземпляре EC2, созданном вручную.
- Диспетчер задач работает на экземпляре EC2, созданном ECS как часть ASG. Диспетчер задач работает в контейнере на ECS
- Я могу свернуть менеджер заданий из узла диспетчера задач
- Диспетчер задач и диспетчер заданий взаимодействуют через RPC.
- Диспетчер задач не разрешает адрес диспетчеру заданий
Почему моя задача не подключается? Я также пробовал общедоступный IP-адрес (v4) и частный IP-адрес (v4).