Hi Piotr,
Thank you very much for your reply. Yes, I have tried to open these ports when I create the services. If I create them with: docker service create --name jobmanager --env JOB_MANAGER_RPC_ADDRESS=jobmanager -p 8081:8081 -p 6123:6123 -p 48081:48081 --network overlay --constraint 'node.hostname == ubuntu-swarm-manager' flink jobmanager docker service create --name taskmanager --env JOB_MANAGER_RPC_ADDRESS=jobmanager -p 6121:6121 -p 6122:6122 --network overlay --constraint 'node.hostname != ubuntu-swarm-manager' flink taskmanager I still get the same issue. Thank you very much for taking your time to look at this. Best wishes, Thalita ________________________________ From: Piotr Nowojski <pi...@data-artisans.com> Sent: 02 November 2017 14:26:32 To: Vergilio, Thalita Cc: user@flink.apache.org Subject: Re: Docker-Flink Project: TaskManagers can't talk to JobManager if they are on different nodes Did you try to expose required ports that are listed in the README when starting the containers? https://github.com/apache/flink/tree/master/flink-contrib/docker-flink Ports: • The Web Client is on port 48081 • JobManager RPC port 6123 (default, not exposed to host) • TaskManagers RPC port 6122 (default, not exposed to host) • TaskManagers Data port 6121 (default, not exposed to host) Piotrek On 2 Nov 2017, at 14:44, javalass <t.vergilio4...@student.leedsbeckett.ac.uk<mailto:t.vergilio4...@student.leedsbeckett.ac.uk>> wrote: I am using the Docker-Flink project in: https://github.com/apache/flink/tree/master/flink-contrib/docker-flink I am creating the services with the following commands: docker network create -d overlay overlay docker service create --name jobmanager --env JOB_MANAGER_RPC_ADDRESS=jobmanager -p 8081:8081 --network overlay --constraint 'node.hostname == ubuntu-swarm-manager' flink jobmanager docker service create --name taskmanager --env JOB_MANAGER_RPC_ADDRESS=jobmanager --network overlay --constraint 'node.hostname != ubuntu-swarm-manager' flink taskmanager I wonder if there's any configuration I'm missing. This is the error I get: - Trying to register at JobManager akka.tcp://flink@jobmanager:6123/ user/jobmanager (attempt 4, timeout: 4000 milliseconds) -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ To view the terms under which this email is distributed, please go to:- http://disclaimer.leedsbeckett.ac.uk/disclaimer/disclaimer.html
