From d2ea5316ad1ffd7cb142aeb539951d2b7ae91246 Mon Sep 17 00:00:00 2001
From: "Mr.An" <42627702+snowmoon-dev@users.noreply.github.com>
Date: Tue, 19 Jul 2022 17:48:16 +0800
Subject: [PATCH] [Fix-11003]Task group queue is not updated to final state
 (#11004)

* fix after the task group is forced to start the task. Task group status has not changed

(cherry picked from commit d7df89990965155e7695da402dcf322ec276355a)
---
 .../dolphinscheduler/service/process/ProcessServiceImpl.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessServiceImpl.java b/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessServiceImpl.java
index 14c998517e..3dfca6e764 100644
--- a/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessServiceImpl.java
+++ b/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessServiceImpl.java
@@ -2955,7 +2955,7 @@ public class ProcessServiceImpl implements ProcessService {
             return null;
         }
         try {
-            while (taskGroupMapper.releaseTaskGroupResource(taskGroup.getId(), taskGroup.getUseSize()
+            while (thisTaskGroupQueue.getForceStart() == Flag.NO.getCode() && taskGroupMapper.releaseTaskGroupResource(taskGroup.getId(), taskGroup.getUseSize()
                 , thisTaskGroupQueue.getId(), TaskGroupQueueStatus.ACQUIRE_SUCCESS.getCode()) != 1) {
                 thisTaskGroupQueue = this.taskGroupQueueMapper.queryByTaskId(taskInstance.getId());
                 if (thisTaskGroupQueue.getStatus() == TaskGroupQueueStatus.RELEASE) {