From 8f86582609aa2d0b91170b443e6c59c5da8cdcb4 Mon Sep 17 00:00:00 2001 From: qiaozhanwei Date: Sat, 12 Oct 2019 14:28:49 +0800 Subject: [PATCH] =?UTF-8?q?add=20queue=20error=EF=BC=8CcheckQueueExist=20a?= =?UTF-8?q?nd=20checkQueueNameExist=20update=20(#997)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit * add ConnectionFactoryTest and ConnectionFactory read datasource from appliction.yml * .escheduler_env.sh to dolphinscheduler_env.sh * dao yml assembly to conf directory * table name modify * entity title table name modify * logback log name modify * running through the big process * running through the big process error modify * logback log name modify * data_source.properties rename * logback log name modify * install.sh optimization * install.sh optimization * command count modify * command state update * countCommandState sql update * countCommandState sql update * remove application.yml file * master.properties modify * install.sh modify * install.sh modify * api server startup modify * the current user quits and the session is completely emptied. bug fix * remove pom package resources * checkQueueNameExist method update * checkQueueExist --- .../dolphinscheduler/api/service/QueueService.java | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/QueueService.java b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/QueueService.java index 7ffcd02fcb..e8655a3c0c 100644 --- a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/QueueService.java +++ b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/QueueService.java @@ -238,22 +238,23 @@ public class QueueService extends BaseService { /** * check queue exist - * + * if exists return true，not exists return false + * check queue exist * @param queue * @return */ private boolean checkQueueExist(String queue) { - return queueMapper.queryAllQueueList(queue, null).size()>0 ? false : true; + return queueMapper.queryAllQueueList(queue, null).size()>0 ? true : false; } /** * check queue name exist - * + * if exists return true，not exists return false * @param queueName * @return */ private boolean checkQueueNameExist(String queueName) { - return queueMapper.queryAllQueueList(null ,queueName).size()>0 ? false : true; + return queueMapper.queryAllQueueList(null ,queueName).size() > 0 ? true : false; } }