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