You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by xi...@apache.org on 2022/06/14 11:59:49 UTC
[iotdb] 01/01: fix the bug that the judgement of hasResultSet is skipped
This is an automated email from the ASF dual-hosted git repository.
xingtanzjr pushed a commit to branch xingtanzjr/fix_query_hasResult
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 6e7677b2f744dd79af8a1fbaade954377b113111
Author: Jinrui.Zhang <xi...@gmail.com>
AuthorDate: Tue Jun 14 19:57:18 2022 +0800
fix the bug that the judgement of hasResultSet is skipped
---
.../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) {