[iotdb] branch add_comment updated: spotless

[qi...@apache.org]

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

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


The following commit(s) were added to refs/heads/add_comment by this push:
     new 45ad8b4c3f spotless
45ad8b4c3f is described below

commit 45ad8b4c3fe6cda68e1d0015ffc92a3d2665a87c
Author: qiaojialin <64...@qq.com>
AuthorDate: Wed Apr 27 21:30:07 2022 +0800

    spotless
---
 .../org/apache/iotdb/db/mpp/schedule/DriverScheduler.java    | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/schedule/DriverScheduler.java b/server/src/main/java/org/apache/iotdb/db/mpp/schedule/DriverScheduler.java
index 63718faa6b..fadf51400d 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/schedule/DriverScheduler.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/schedule/DriverScheduler.java
@@ -147,7 +147,7 @@ public class DriverScheduler implements IDriverScheduler, IService {
         task.lock();
         try {
           task.setAbortCause(FragmentInstanceAbortedException.BY_QUERY_CASCADING_ABORTED);
-          clearFragmentInstanceTask(task);
+          clearDriverTask(task);
         } finally {
           task.unlock();
         }
@@ -164,7 +164,7 @@ public class DriverScheduler implements IDriverScheduler, IService {
     task.lock();
     try {
       task.setAbortCause(FragmentInstanceAbortedException.BY_FRAGMENT_ABORT_CALLED);
-      clearFragmentInstanceTask(task);
+      clearDriverTask(task);
     } finally {
       task.unlock();
     }
@@ -180,7 +180,7 @@ public class DriverScheduler implements IDriverScheduler, IService {
     return task.getSchedulePriority();
   }
 
-  private void clearFragmentInstanceTask(DriverTask task) {
+  private void clearDriverTask(DriverTask task) {
     if (task.getStatus() != DriverTaskStatus.FINISHED) {
       task.setStatus(DriverTaskStatus.ABORTED);
     }
@@ -314,7 +314,7 @@ public class DriverScheduler implements IDriverScheduler, IService {
         }
         task.updateSchedulePriority(context);
         task.setStatus(DriverTaskStatus.FINISHED);
-        clearFragmentInstanceTask(task);
+        clearDriverTask(task);
       } finally {
         task.unlock();
       }
@@ -332,7 +332,7 @@ public class DriverScheduler implements IDriverScheduler, IService {
         logger.warn(
             "The task {} is aborted. All other tasks in the same query will be cancelled",
             task.getId().toString());
-        clearFragmentInstanceTask(task);
+        clearDriverTask(task);
       } finally {
         task.unlock();
       }
@@ -346,7 +346,7 @@ public class DriverScheduler implements IDriverScheduler, IService {
           otherTask.lock();
           try {
             otherTask.setAbortCause(FragmentInstanceAbortedException.BY_QUERY_CASCADING_ABORTED);
-            clearFragmentInstanceTask(otherTask);
+            clearDriverTask(otherTask);
           } finally {
             otherTask.unlock();
           }