[ 
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
(v7.6.3#76005)

Reply via email to