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://
[email protected]:6123/user/rpc/resourcemanager_*, retrying in 10000 ms:
Could not connect to rpc endpoint under address akka.tcp://
[email protected]:6123/user/rpc/resourcemanager_*.
Any pointer on How to fix this?
Thanks
Avijit
