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