[jira] [Assigned] (FLINK-14511) Checking YARN queues should add "root" prefix

["Kostas Kloudas (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-14511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Kostas Kloudas reassigned FLINK-14511:
--------------------------------------

    Assignee: Zhanchun Zhang

> Checking YARN queues should add "root" prefix
> ---------------------------------------------
>
>                 Key: FLINK-14511
>                 URL: https://issues.apache.org/jira/browse/FLINK-14511
>             Project: Flink
>          Issue Type: Bug
>          Components: Deployment / YARN
>            Reporter: Zhanchun Zhang
>            Assignee: Zhanchun Zhang
>            Priority: Major
>              Labels: pull-request-available
>          Time Spent: 10m
>  Remaining Estimate: 0h
>
> As we all know, all queues in the YARN cluster are children of the "root" queue. While submitting an application to "root.product" queue with -qu product parameter, the client logs that "The specified queue 'product' does not exist. Available queues....". But this queue is exist and we can still submit application to YARN cluster, which is confusing for users. So I think that when checking queues should add "root." prefix to the queue name.
> {code:java}
> List<QueueInfo> queues = yarnClient.getAllQueues();
> if (queues.size() > 0 && this.yarnQueue != null) { // check only if there are queues configured in yarn and for this session.
> 	boolean queueFound = false;
> 	for (QueueInfo queue : queues) {
> 		if (queue.getQueueName().equals(this.yarnQueue) {
> 			queueFound = true;
> 			break;
> 		}
> 	}
> 	if (!queueFound) {
> 		String queueNames = "";
> 		for (QueueInfo queue : queues) {
> 			queueNames += queue.getQueueName() + ", ";
> 		}
> 		LOG.warn("The specified queue '" + this.yarnQueue + "' does not exist. " +
> 				"Available queues: " + queueNames);
> 	}
> {code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)