[
https://issues.apache.org/jira/browse/FLINK-8305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-8305.
--------------------------------
Resolution: Not A Problem
This should work now with the REST job submission.
> 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: Deployment / Docker
> Affects Versions: 1.3.2, 1.4.0
> Environment: Mac OSX, Docker 17.09.1-ce-mac42 (21090)
> Reporter: Thomas Wozniakowski
> Priority: Major
>
> 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}}
> gives you:
> ||CONTAINER ID||IMAGE||COMMAND||CREATED||STATUS||PORTS||NAMES||
> |e2dd5f668f4f|flink|"/docker-entrypoin..."|6 minutes ago|Up 6
> minutes|8081/tcp, 0.0.0.0:32789->6123/tcp|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
(v8.3.4#803005)
