Hi Avijit, I think you need to create a network via "docker network create flink-network". And then use "docker run ... --name=jobmanager --network flink-network" to set the hostname. Also "jobmanager.rpc.address" need to be set the jobmanager. Refer the doc[1] for more information.
If you really do not want to create a network and still want to use the port forward directly. Then you need to set the "jobmanager.rpc.address" to a local ip address, for example, 192.168.0.100, not 127.0.0.1. Since 127.0.0.1 in docker container means a container local address, not host machine local address. [1]. https://ci.apache.org/projects/flink/flink-docs-stable/ops/deployment/docker.html#start-a-session-cluster Best, Yang Avijit Saha <avij...@gmail.com> 于2020年7月23日周四 上午1:14写道： > Hi, > I have built a docker image containing both Flink 1.11 and the job jar as > per instructions at: > > https://ci.apache.org/projects/flink/flink-docs-stable/ops/deployment/docker.html > > > The jobanager starts up fine as follows: > > - FLINK_PROPERTIES="jobmanager.rpc.address: 127.0.0.1" > - docker run --env FLINK_PROPERTIES={"${FLINK_PROPERTIES}" -p > 0.0.0.0:6123:6123/tcp > flink_with_job_artifacts standalone-job > --job-classname=org.apache.beam.examples.WordCount --runner=FlinkRunner > --inputFile=/opt/flink/conf/flink-conf.yaml --output=/tmp/counts > > > > Now, when launching the taskmanager as follows: > - FLINK_PROPERTIES="jobmanager.rpc.address: 127.0.0.1" > - docker run --env FLINK_PROPERTIES="${FLINK_PROPERTIES}" > flink_with_job_artifacts taskmanager, > the taskmanager fails with the following: > > ......... > 2020-07-22 16:55:25,974 INFO org.apache.flink.runtime.net.ConnectionUtils > [] - Failed to connect from address '/127.0.0.1': > Connection refused (Connection refused) > ........ > 2020-07-22 16:55:32,709 INFO > org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Could > not resolve ResourceManager address akka.tcp:// > flink@127.0.0.1:6123/user/rpc/resourcemanager_*, retrying in 10000 ms: > Could not connect to rpc endpoint under address akka.tcp:// > flink@127.0.0.1:6123/user/rpc/resourcemanager_*. > > > Any pointer on How to fix this? > > Thanks > Avijit >
