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