[FLINK-15852] Job is submitted to the wrong session cluster

• Type: Bug
• Status: Closed
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 1.10.0
• Fix Version/s: 1.10.1, 1.11.0
• Component/s: Command Line Client
• Labels: pull-request-available
• Assignee: Kostas Kloudas
• Reporter: Canbin Zheng
• Created: 03/Feb/20 04:07
• Updated: 20/Mar/20 01:18
• Resolved: 19/Mar/20 16:05

Description

Steps to reproduce the problem:

1. Deploy a YARN session cluster by command ./bin/yarn-session.sh -d
2. Deploy a Kubernetes session cluster by command ./bin/kubernetes-session.sh -Dkubernetes.cluster-id=test ...
3. Try to submit a Job to the Kubernetes session cluster by command ./bin/flink run -d -e kubernetes-session -Dkubernetes.cluster-id=test examples/streaming/WordCount.jar

It's expected that the Job will be submitted to the Kubernetes session cluster whose cluster-id is test, however, the job was submitted to the YARN session cluster.

 

Issue Links

• links to: GitHub Pull Request #11435