This is an automated email from the ASF dual-hosted git repository. ycycse pushed a commit to branch ycy/fixTableTraining in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 8b803fb6ae4289abf34573d165fed15c7ca45400 Author: YangCaiyin <[email protected]> AuthorDate: Thu Jun 12 11:15:47 2025 +0800 fix create model for training --- .../main/java/org/apache/iotdb/confignode/manager/ConfigManager.java | 2 +- .../db/queryengine/plan/execution/config/TableConfigTaskVisitor.java | 4 ++-- iotdb-protocol/thrift-confignode/src/main/thrift/confignode.thrift | 1 - 3 files changed, 3 insertions(+), 4 deletions(-) diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java index cbd67795774..51ee89742a3 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java @@ -2671,7 +2671,7 @@ public class ConfigManager implements IManager { } } for (String tableName : dataSchemaForTable.getTableList()) { - dataSchemaList.add(new IDataSchema(dataSchemaForTable.curDatabase + DOT + tableName)); + dataSchemaList.add(new IDataSchema(tableName)); } return dataSchemaList; } diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/TableConfigTaskVisitor.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/TableConfigTaskVisitor.java index a169096341f..95d9ecaa278 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/TableConfigTaskVisitor.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/TableConfigTaskVisitor.java @@ -1377,8 +1377,8 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont node.isUseAllData(), node.getTargetTimeRanges(), node.getExistingModelId(), - node.getTargetDbs(), - tableList); + tableList, + node.getTargetDbs()); } @Override diff --git a/iotdb-protocol/thrift-confignode/src/main/thrift/confignode.thrift b/iotdb-protocol/thrift-confignode/src/main/thrift/confignode.thrift index 3f4c42d058a..f767f35d67c 100644 --- a/iotdb-protocol/thrift-confignode/src/main/thrift/confignode.thrift +++ b/iotdb-protocol/thrift-confignode/src/main/thrift/confignode.thrift @@ -1088,7 +1088,6 @@ struct TUpdateModelInfoReq { struct TDataSchemaForTable{ 1: required list<string> databaseList 2: required list<string> tableList - 3: required string curDatabase } struct TDataSchemaForTree{
