[
https://issues.apache.org/jira/browse/FLINK-8305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16308452#comment-16308452
]
Thomas Wozniakowski commented on FLINK-8305:
--------------------------------------------
Hi Aljoscha,
Thanks for responding! I actually ended up working this out by banging my head
against it for another day or so. You're right, using 1:1 port mappings does
work, but the Docker images don't allow a deterministic way to override most
internal port configuration in Local Cluster mode, so I've raised a Github PR
to allow this:
https://github.com/docker-flink/docker-flink/pull/33
> 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.4.0, 1.3.2
> 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}}
> 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
(v6.4.14#64029)
