[FLINK-24963][yarn] Improve output of queue names

lightClouds917 · Nov 25, 2021 · 1356888 · 1356888
1 parent a84e38a
commit 1356888
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java b/flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java
@@ -744,10 +744,7 @@ private void checkYarnQueues(YarnClient yarnClient) {
                     }
                 }
                 if (!queueFound) {
-                    String queueNames = "";
-                    for (QueueInfo queue : queues) {
-                        queueNames += queue.getQueueName() + ", ";
-                    }
+                    String queueNames = StringUtils.toQuotedListString(queues.toArray());
                     LOG.warn(
                             "The specified queue '"
                                     + this.yarnQueue