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

["Zhanchun Zhang (Jira)" <ji...@apache.org>]

Zhanchun Zhang created FLINK-14511:
--------------------------------------

             Summary: 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
         Environment: 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 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);
	}
} else {
{code}

            Reporter: Zhanchun Zhang






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