From 6f6553b81bcc73d83e20aeef16f45fa9d7b0e256 Mon Sep 17 00:00:00 2001 From: "luke.miao" <282583553@qq.com> Date: Tue, 17 Dec 2024 10:15:57 +0800 Subject: [PATCH] Fix IT failure issue --- .../db/protocol/rest/table/v1/impl/RestApiServiceImpl.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest/table/v1/impl/RestApiServiceImpl.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest/table/v1/impl/RestApiServiceImpl.java index e01901ac18eb..ae46d71d68fd 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest/table/v1/impl/RestApiServiceImpl.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest/table/v1/impl/RestApiServiceImpl.java @@ -39,7 +39,6 @@ import org.apache.iotdb.db.queryengine.plan.execution.IQueryExecution; import org.apache.iotdb.db.queryengine.plan.planner.LocalExecutionPlanner; import org.apache.iotdb.db.queryengine.plan.relational.metadata.Metadata; -import org.apache.iotdb.db.queryengine.plan.relational.sql.ast.Statement; import org.apache.iotdb.db.queryengine.plan.relational.sql.parser.SqlParser; import org.apache.iotdb.db.queryengine.plan.statement.crud.InsertTabletStatement; import org.apache.iotdb.db.utils.CommonUtils; @@ -71,7 +70,7 @@ public Response executeQueryStatement(SQL sql, SecurityContext securityContext) throws NotFoundException { SqlParser relationSqlParser = new SqlParser(); Long queryId = null; - Statement statement = null; + org.apache.iotdb.db.queryengine.plan.relational.sql.ast.Statement statement = null; long startTime = System.nanoTime(); try { IClientSession clientSession = SESSION_MANAGER.getCurrSessionAndUpdateIdleTime(); @@ -192,7 +191,7 @@ public Response executeNonQueryStatement(SQL sql, SecurityContext securityContex throws NotFoundException { SqlParser relationSqlParser = new SqlParser(); Long queryId = null; - Statement statement = null; + org.apache.iotdb.db.queryengine.plan.relational.sql.ast.Statement statement = null; long startTime = System.nanoTime(); try { IClientSession clientSession = SESSION_MANAGER.getCurrSessionAndUpdateIdleTime();