[iotdb] branch master updated: Fixed resource stop failure after remote scheduling retry

[jackietien]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 8cd4c61a1c Fixed resource stop failure after remote scheduling retry
8cd4c61a1c is described below

commit 8cd4c61a1cd91822c425d2af767a9e609c552d10
Author: Zhijia Cao <caozhi...@126.com>
AuthorDate: Mon Apr 17 15:02:09 2023 +0800

    Fixed resource stop failure after remote scheduling retry
---
 .../java/org/apache/iotdb/db/mpp/plan/execution/QueryExecution.java     | 2 ++
 1 file changed, 2 insertions(+)

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 3588cc4462..e75b8e39c0 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
@@ -256,6 +256,8 @@ public class QueryExecution implements IQueryExecution {
     context.prepareForRetry();
     // re-analyze the query
     this.analysis = analyze(rawStatement, context, partitionFetcher, 
schemaFetcher);
+    // re-stop
+    this.stopped = new AtomicBoolean(false);
     // re-start the QueryExecution
     this.start();
     return getStatus();