This is an automated email from the ASF dual-hosted git repository. shuwenwei pushed a commit to branch calc_commons in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 7266836a10b9ac7279b020cf8843446c15b5b75e Author: shuwenwei <[email protected]> AuthorDate: Wed Apr 15 15:32:07 2026 +0800 fix --- .../mqtt/src/main/java/org/apache/iotdb/mqtt/MPPPublishHandler.java | 6 +++--- .../iotdb/rest/protocol/table/v1/impl/RestApiServiceImpl.java | 5 +++-- .../org/apache/iotdb/rest/protocol/v2/impl/RestApiServiceImpl.java | 2 +- 3 files changed, 7 insertions(+), 6 deletions(-) diff --git a/external-service-impl/mqtt/src/main/java/org/apache/iotdb/mqtt/MPPPublishHandler.java b/external-service-impl/mqtt/src/main/java/org/apache/iotdb/mqtt/MPPPublishHandler.java index 395447e9734..24a34d391f4 100644 --- a/external-service-impl/mqtt/src/main/java/org/apache/iotdb/mqtt/MPPPublishHandler.java +++ b/external-service-impl/mqtt/src/main/java/org/apache/iotdb/mqtt/MPPPublishHandler.java @@ -25,7 +25,7 @@ import org.apache.iotdb.commons.schema.table.column.TsTableColumnCategory; import org.apache.iotdb.db.auth.AuthorityChecker; import org.apache.iotdb.db.conf.IoTDBConfig; import org.apache.iotdb.db.conf.IoTDBDescriptor; -import org.apache.iotdb.db.protocol.session.IClientSession; +import org.apache.iotdb.db.node_commons.common.SqlDialect; import org.apache.iotdb.db.protocol.session.MqttClientSession; import org.apache.iotdb.db.protocol.session.SessionManager; import org.apache.iotdb.db.queryengine.plan.Coordinator; @@ -105,7 +105,7 @@ public class MPPPublishHandler extends AbstractInterceptHandler { ZoneId.systemDefault().toString(), TSProtocolVersion.IOTDB_SERVICE_PROTOCOL_V3, ClientVersion.V_1_0, - useTableInsert ? IClientSession.SqlDialect.TABLE : IClientSession.SqlDialect.TREE); + useTableInsert ? SqlDialect.TABLE : SqlDialect.TREE); sessionManager.registerSessionForMqtt(session); clientIdToSessionMap.put(msg.getClientID(), session); } @@ -173,7 +173,7 @@ public class MPPPublishHandler extends AbstractInterceptHandler { TimestampPrecisionUtils.checkTimestampPrecision(message.getTimestamp()); InsertTabletStatement insertTabletStatement = constructInsertTabletStatement(message); session.setDatabaseName(message.getDatabase().toLowerCase()); - session.setSqlDialect(IClientSession.SqlDialect.TABLE); + session.setSqlDialect(SqlDialect.TABLE); long queryId = sessionManager.requestQueryId(); SqlParser relationSqlParser = new SqlParser(); Metadata metadata = LocalExecutionPlanner.getInstance().metadata; diff --git a/external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol/table/v1/impl/RestApiServiceImpl.java b/external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol/table/v1/impl/RestApiServiceImpl.java index 215f4d948d3..87f60bddd7d 100644 --- a/external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol/table/v1/impl/RestApiServiceImpl.java +++ b/external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol/table/v1/impl/RestApiServiceImpl.java @@ -21,6 +21,7 @@ import org.apache.iotdb.common.rpc.thrift.TSStatus; import org.apache.iotdb.db.conf.IoTDBConfig; import org.apache.iotdb.db.conf.IoTDBDescriptor; import org.apache.iotdb.db.conf.rest.IoTDBRestServiceDescriptor; +import org.apache.iotdb.db.node_commons.common.SqlDialect; import org.apache.iotdb.db.node_commons.plan.relational.sql.ast.Statement; import org.apache.iotdb.db.protocol.session.IClientSession; import org.apache.iotdb.db.protocol.session.SessionManager; @@ -156,7 +157,7 @@ public class RestApiServiceImpl extends RestApiService { StatementConstructionHandler.constructInsertTabletStatement(insertTabletRequest); IClientSession clientSession = SESSION_MANAGER.getCurrSession(); clientSession.setDatabaseName(insertTabletRequest.getDatabase()); - clientSession.setSqlDialect(IClientSession.SqlDialect.TABLE); + clientSession.setSqlDialect(SqlDialect.TABLE); queryId = SESSION_MANAGER.requestQueryId(); Metadata metadata = LocalExecutionPlanner.getInstance().metadata; @@ -286,7 +287,7 @@ public class RestApiServiceImpl extends RestApiService { clientSession.setDatabaseName(sql.getDatabase()); } - clientSession.setSqlDialect(IClientSession.SqlDialect.TABLE); + clientSession.setSqlDialect(SqlDialect.TABLE); return relationSqlParser.createStatement(sql.getSql(), ZoneId.systemDefault(), clientSession); } diff --git a/external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol/v2/impl/RestApiServiceImpl.java b/external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol/v2/impl/RestApiServiceImpl.java index f6c42533a62..6a7f08c6d8b 100644 --- a/external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol/v2/impl/RestApiServiceImpl.java +++ b/external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol/v2/impl/RestApiServiceImpl.java @@ -22,10 +22,10 @@ import org.apache.iotdb.commons.path.PartialPath; import org.apache.iotdb.db.conf.IoTDBConfig; import org.apache.iotdb.db.conf.IoTDBDescriptor; import org.apache.iotdb.db.conf.rest.IoTDBRestServiceDescriptor; +import org.apache.iotdb.db.node_commons.common.SessionInfo; import org.apache.iotdb.db.protocol.session.IClientSession; import org.apache.iotdb.db.protocol.session.SessionManager; import org.apache.iotdb.db.protocol.thrift.OperationType; -import org.apache.iotdb.db.queryengine.common.SessionInfo; import org.apache.iotdb.db.queryengine.plan.Coordinator; import org.apache.iotdb.db.queryengine.plan.analyze.ClusterPartitionFetcher; import org.apache.iotdb.db.queryengine.plan.analyze.IPartitionFetcher;
