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

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


The following commit(s) were added to refs/heads/QueryExecutionSafe by this 
push:
     new 8acf533865 Add some comments
8acf533865 is described below

commit 8acf5338656805515be47721242fcf18c3dc8fbf
Author: JackieTien97 <[email protected]>
AuthorDate: Fri Apr 28 09:27:25 2023 +0800

    Add some comments
---
 .../java/org/apache/iotdb/db/mpp/plan/execution/QueryExecution.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/QueryExecution.java
 
b/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/QueryExecution.java
index c6c82c8f20..0da5805f97 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/QueryExecution.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/QueryExecution.java
@@ -456,7 +456,7 @@ public class QueryExecution implements IQueryExecution {
     while (true) {
       try {
         ListenableFuture<?> blocked;
-        synchronized (resultHandle) {
+        synchronized (resultHandle) { // make sure isAborted and isBlocked are 
an atomic operation
           if (resultHandle.isAborted()) {
             logger.warn("[ResultHandleAborted]");
             stateMachine.transitionToAborted();

Reply via email to