[iotdb] branch master updated: fix the bug that the judgement of hasResultSet is skipped (#6284)

[qiaojialin]

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

qiaojialin 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 73b4253ab9 fix the bug that the judgement of hasResultSet is skipped 
(#6284)
73b4253ab9 is described below

commit 73b4253ab9a5e09355ea1e0d28242b0ad5e6d5ad
Author: Zhang.Jinrui <xingtan...@gmail.com>
AuthorDate: Tue Jun 14 20:04:41 2022 +0800

    fix the bug that the judgement of hasResultSet is skipped (#6284)
---
 .../apache/iotdb/db/service/thrift/impl/DataNodeTSIServiceImpl.java   | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/DataNodeTSIServiceImpl.java
 
b/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/DataNodeTSIServiceImpl.java
index 2c2edcd03e..f467d6393d 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/DataNodeTSIServiceImpl.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/DataNodeTSIServiceImpl.java
@@ -626,7 +626,9 @@ public class DataNodeTSIServiceImpl implements 
TSIEventHandler {
         resp.setIsAlign(true);
 
         QUERY_TIME_MANAGER.unRegisterQuery(req.queryId, false);
-        COORDINATOR.removeQueryExecution(req.queryId);
+        if (!hasResultSet) {
+          COORDINATOR.removeQueryExecution(req.queryId);
+        }
         return resp;
       }
     } catch (Exception e) {