You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by hu...@apache.org on 2022/05/30 11:44:32 UTC
[iotdb] 03/03: throw SemanticException in ASTVisitor
This is an automated email from the ASF dual-hosted git repository.
hui pushed a commit to branch lmh/GroupByDebug
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit b1dd10912d618b772b396194ab2672fc17611610
Author: liuminghui233 <54...@qq.com>
AuthorDate: Mon May 30 19:43:58 2022 +0800
throw SemanticException in ASTVisitor
---
.../thrift/impl/DataNodeTSIServiceImpl.java | 24 +++++++++++-----------
1 file changed, 12 insertions(+), 12 deletions(-)
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 547e86dd6c..412301327f 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
@@ -530,20 +530,20 @@ public class DataNodeTSIServiceImpl implements TSIEventHandler {
}
long startTime = System.currentTimeMillis();
- Statement s =
- StatementGenerator.createStatement(
- statement, SESSION_MANAGER.getZoneId(req.getSessionId()));
-
- // permission check
- TSStatus status = AuthorityChecker.checkAuthority(s, req.sessionId);
- if (status.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
- return RpcUtils.getTSExecuteStatementResp(status);
- }
+ try {
+ Statement s =
+ StatementGenerator.createStatement(
+ statement, SESSION_MANAGER.getZoneId(req.getSessionId()));
- QUERY_FREQUENCY_RECORDER.incrementAndGet();
- AUDIT_LOGGER.debug("Session {} execute Query: {}", req.sessionId, statement);
+ // permission check
+ TSStatus status = AuthorityChecker.checkAuthority(s, req.sessionId);
+ if (status.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
+ return RpcUtils.getTSExecuteStatementResp(status);
+ }
+
+ QUERY_FREQUENCY_RECORDER.incrementAndGet();
+ AUDIT_LOGGER.debug("Session {} execute Query: {}", req.sessionId, statement);
- try {
long queryId = SESSION_MANAGER.requestQueryId(req.statementId, true);
// create and cache dataset
ExecutionResult result =