You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/01/31 10:53:00 UTC

[jira] [Closed] (FLINK-8305) Docker port mapping doesn't work for JobManager RPC port on Official Flink image

     [ 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)