flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Alex (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-11798) Incorrect Kubernetes Documentation
Date Thu, 07 Mar 2019 19:49:00 GMT

    [ https://issues.apache.org/jira/browse/FLINK-11798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16787142#comment-16787142

Alex commented on FLINK-11798:

[~pritesh-patel], unfortunately the docker entry point for public Flink 1.7 docker images
doesn't pass additional arguments to Task Manager.
I wasn't aware of it, as I was using https://github.com/apache/flink/blob/release-1.7/flink-container/docker/docker-entrypoint.sh
for the reference.

There is a [PR|https://github.com/docker-flink/docker-flink/pull/68] to allow passing additional
arguments to Task Manager.
But to make the described option take the effect, either Flink 1.7.2 docker images need to
be rebuilt and retagged OR wait when the updated scripts would be included in some other Flink
1.7.x release.

> Incorrect Kubernetes Documentation
> ----------------------------------
>                 Key: FLINK-11798
>                 URL: https://issues.apache.org/jira/browse/FLINK-11798
>             Project: Flink
>          Issue Type: Bug
>          Components: Deployment / Kubernetes
>    Affects Versions: 1.7.2
>            Reporter: Pritesh Patel
>            Assignee: Alex
>            Priority: Major
> I have been trying to use the kubernetes session cluster manifests provided in the documentation.
The -Dtaskmanager.host flag doesn't seem to pass through, meaning it uses the pod name as
the host name. This wont work.
> The current docs state the args should be:
> {code:java}
> args: 
> - taskmanager 
> - "-Dtaskmanager.host=$(K8S_POD_IP)"
> {code}
> I did manage to get it to work by using this manifest for the taskmanager instead. This
did waste alot of time as it was very hard to find.
> {code:java}
> args: 
> - taskmanager.sh
> - -Dtaskmanager.host=$(K8S_POD_IP)
> - -Djobmanager.rpc.address=$(JOB_MANAGER_RPC_ADDRESS) 
> {code}

This message was sent by Atlassian JIRA

View raw message