Во-первых, я полный новичок с Флинком.Я установил Apache Flink на Windows.Я начинаю Flink с start-cluster.bat.Он печатает
Запуск локального кластера с одним процессом JobManager и одним процессом TaskManager.Вы можете завершить процессы с помощью CTRL-C в порожденных окнах оболочки.Веб-интерфейс по умолчанию http://localhost:8081/.
В любом случае, когда я отправляю работу, у меня появляется куча сообщений:
DEBUG org.apache.flink.runtime.rest.RestClient - Получен ответ {"status": {"id": "IN_PROGRESS"}}.
В журнале в веб-интерфейсе на http://localhost:8081/, Я вижу:
2019-02-15 16: 04: 23.571 [flink-akka.actor.default-dispatcher-4] WARN akka.remote.ReliableDeliverySupervisor flink-akka.remote.default-remote-dispatcher-6 -Ассоциация с удаленной системой [akka.tcp: //flink@127.0.0.1: 56404] не удалась, теперь адрес стробируется в течение [50] мс.Причина: [Disassociated]
Если я перехожу на вкладку «Диспетчер задач», она пуста.
Я пытался найти, используется ли какой-либо порт, необходимый для flink, но он не работаеткажется, дело в этом.
Есть идеи, чтобы решить эту проблему?