diff --git a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/DataAnalysisService.java b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/DataAnalysisService.java
index 034138d2ce..00ba278705 100644
--- a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/DataAnalysisService.java
+++ b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/DataAnalysisService.java
@@ -348,7 +348,7 @@ public class DataAnalysisService extends BaseService{
         for (String taskQueueStr : tasksQueueList){
             if (StringUtils.isNotEmpty(taskQueueStr)){
                 String[] splits = taskQueueStr.split("_");
-                if (splits.length == 4){
+                if (splits.length >= 4){
                     tasksQueueIds[i++]=Integer.parseInt(splits[3]);
                 }
             }