[iotdb] 02/02: Avoid reserverSize is decreased more than once

[xiangweiwei]

This is an automated email from the ASF dual-hosted git repository.

xiangweiwei pushed a commit to branch dependencyBug
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit cffeb9df1b9795ada2b46170aa821e984c252c8d
Author: Alima777 <wxw19981...@gmail.com>
AuthorDate: Wed Mar 22 21:58:43 2023 +0800

    Avoid reserverSize is decreased more than once
---
 .../org/apache/iotdb/db/mpp/execution/schedule/DriverScheduler.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/DriverScheduler.java
 
b/server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/DriverScheduler.java
index 5179a57b3a..6cd893f441 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/DriverScheduler.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/DriverScheduler.java
@@ -311,7 +311,6 @@ public class DriverScheduler implements IDriverScheduler, 
IService {
           readyQueue.decreaseReservedSize();
           break;
         case FINISHED:
-          readyQueue.decreaseReservedSize();
           break;
       }
 
@@ -482,6 +481,7 @@ public class DriverScheduler implements IDriverScheduler, 
IService {
         }
         task.updateSchedulePriority(context);
         task.setStatus(DriverTaskStatus.FINISHED);
+        readyQueue.decreaseReservedSize();
       } finally {
         task.unlock();
       }