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 <[email protected]> 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) {
