[
https://issues.apache.org/jira/browse/FLINK-16598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Canbin Zheng updated FLINK-16598:
---------------------------------
Description:
Steps to reproduce the problem:
# Start a Kubernetes session cluster, by default, the rest port exposed by the
rest Service is 8081.
# Submit a job to the session cluster, but specify a different rest port via
-Drest.port=8082.
As we can see, the job could never be submitted to the existing session cluster
since we retrieve the port of the Endpoint from the Flink configuration object
instead of the created Service.
was:
Steps to reproduce the problem:
# Start a Kubernetes session cluster, by default, the rest port exposed by the
rest Service is 8081.
# Submit a job to the session cluster, but specify a different rest port via
-Drest.port=8082
As we can see, the job could never be submitted to the existing session cluster
since we retrieve the Endpoint from the Flink configuration object instead of
the created Service.
> Respect the rest port exposed by Service in
> Fabric8FlinkKubeClient#getRestEndpoint
> ----------------------------------------------------------------------------------
>
> Key: FLINK-16598
> URL: https://issues.apache.org/jira/browse/FLINK-16598
> Project: Flink
> Issue Type: Bug
> Components: Deployment / Kubernetes
> Affects Versions: 1.10.0
> Reporter: Canbin Zheng
> Priority: Major
> Fix For: 1.11.0
>
>
> Steps to reproduce the problem:
> # Start a Kubernetes session cluster, by default, the rest port exposed by
> the rest Service is 8081.
> # Submit a job to the session cluster, but specify a different rest port via
> -Drest.port=8082.
> As we can see, the job could never be submitted to the existing session
> cluster since we retrieve the port of the Endpoint from the Flink
> configuration object instead of the created Service.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
