Thomas Wozniakowski created FLINK-8305:
------------------------------------------
Summary: Docker port mapping doesn't work for JobManager RPC port on Official Flink image
Key: FLINK-8305
URL:
https://issues.apache.org/jira/browse/FLINK-8305 Project: Flink
Issue Type: Bug
Components: Docker
Affects Versions: 1.3.2, 1.4.0
Environment: Mac OSX, Docker 17.09.1-ce-mac42 (21090)
Reporter: Thomas Wozniakowski
With the images at:
https://hub.docker.com/r/_/flink/. The JobManager RPC port does not appear to be properly exposed via a standard docker port mapping.
Starting a local cluster with:
{{docker run --name flink_local -p 32789:6123 -t -d flink local}}
Should allow submission of a job via command line with:
{{flink run -m 0.0.0.0:32789 /usr/local/Cellar/apache-flink/1.3.2/libexec/examples/streaming/WordCount.jar}}
But this fails with "Couldn't retrieve the JobExecutionResult from the JobManager".
Logging directly into the container with:
{{sudo docker exec -it <CONTAINER_ID> /bin/bash}}
allows you to successfully start and complete job with:
{{flink run -m localhost:6123 /opt/flink/examples/streaming/WordCount.jar}}
What am I missing here? If the job can be successfully submitted to 6123 locally, and that port is mapped to an external port on 0.0.0.0, then I should be able to submit jobs to that port? I can't find any way to make this work though. I've tried all variants of host name (localhost, 127.0.0.1, 0.0.0.0) and none work.
I would hugely appreciate any help.
Thanks guys.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
Locked
