You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2023/01/05 08:07:00 UTC

[iotdb] branch IOTDB-5365 created (now 7ea3ff98a9)

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

jackietien pushed a change to branch IOTDB-5365
in repository https://gitbox.apache.org/repos/asf/iotdb.git


      at 7ea3ff98a9 [IOTDB-5365] Init lastEnterReadyQueueTime of DriverTask while creating it

This branch includes the following new commits:

     new 7ea3ff98a9 [IOTDB-5365] Init lastEnterReadyQueueTime of DriverTask while creating it

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.



[iotdb] 01/01: [IOTDB-5365] Init lastEnterReadyQueueTime of DriverTask while creating it

Posted by ja...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

jackietien pushed a commit to branch IOTDB-5365
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit 7ea3ff98a9834e6634b5c781025d02a96140d187
Author: JackieTien97 <ja...@gmail.com>
AuthorDate: Thu Jan 5 16:06:43 2023 +0800

    [IOTDB-5365] Init lastEnterReadyQueueTime of DriverTask while creating it
---
 .../java/org/apache/iotdb/db/mpp/execution/schedule/DriverScheduler.java | 1 +
 1 file changed, 1 insertion(+)

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 b7718b5236..f4b836a511 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
@@ -180,6 +180,7 @@ public class DriverScheduler implements IDriverScheduler, IService {
         }
         timeoutQueue.push(task);
         readyQueue.push(task);
+        task.setLastEnterReadyQueueTime(System.nanoTime());
       } finally {
         task.unlock();
       }