You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2022/10/19 09:24:51 UTC
[iotdb] branch IOTDB-4619 updated: require statementId from sessionId
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch IOTDB-4619
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/IOTDB-4619 by this push:
new 58289d6d0a require statementId from sessionId
58289d6d0a is described below
commit 58289d6d0af1331ea041915c4ca130be79a567e6
Author: JackieTien97 <ja...@gmail.com>
AuthorDate: Wed Oct 19 17:24:43 2022 +0800
require statementId from sessionId
---
.../iotdb/db/service/thrift/impl/DataNodeInternalRPCServiceImpl.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/DataNodeInternalRPCServiceImpl.java b/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/DataNodeInternalRPCServiceImpl.java
index 8921240c48..690070bff6 100644
--- a/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/DataNodeInternalRPCServiceImpl.java
+++ b/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/DataNodeInternalRPCServiceImpl.java
@@ -626,7 +626,8 @@ public class DataNodeInternalRPCServiceImpl implements IDataNodeRPCService.Iface
QUERY_FREQUENCY_RECORDER.incrementAndGet();
- long queryId = SESSION_MANAGER.requestQueryId(0L, true);
+ long queryId =
+ SESSION_MANAGER.requestQueryId(SESSION_MANAGER.requestStatementId(sessionId), true);
// create and cache dataset
ExecutionResult result =
COORDINATOR.execute(