You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by xi...@apache.org on 2023/03/22 13:59:07 UTC

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

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 <wx...@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();
       }