[ https://issues.apache.org/jira/browse/FLINK-8305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16308269#comment-16308269 ]
Aljoscha Krettek commented on FLINK-8305: ----------------------------------------- This is a known issue based on a "feature" of Akka: Akka connections only work if they client connects to the server with exactly the same address that the server "thinks" it has. I think you can work around this by adding {{EXPOSE 6123}} to your Dockerfile and using exactly that port and from an environment that can use the hostname of the JobManager. > 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)