This is an automated email from the ASF dual-hosted git repository. yongzao pushed a commit to branch rc/2.0.6 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 49fbdbcbda732285c71b356017607a6c0796f69d Author: Yongzao <[email protected]> AuthorDate: Sat Sep 13 19:46:18 2025 +0800 [AINode] Fix bugs for SHOW LOADED MODELS (#16410) (cherry picked from commit 40b2b33964e647f3bbcce4d5bc05fc6df2ed7653) --- iotdb-core/ainode/iotdb/ainode/core/constant.py | 6 +++--- .../plan/execution/config/executor/ClusterConfigTaskExecutor.java | 2 ++ iotdb-protocol/thrift-ainode/src/main/thrift/ainode.thrift | 2 +- iotdb-protocol/thrift-confignode/src/main/thrift/confignode.thrift | 2 +- 4 files changed, 7 insertions(+), 5 deletions(-) diff --git a/iotdb-core/ainode/iotdb/ainode/core/constant.py b/iotdb-core/ainode/iotdb/ainode/core/constant.py index c351d74db02..9b3952b431d 100644 --- a/iotdb-core/ainode/iotdb/ainode/core/constant.py +++ b/iotdb-core/ainode/iotdb/ainode/core/constant.py @@ -35,11 +35,11 @@ AINODE_SYSTEM_FILE_NAME = "system.properties" # AINode cluster configuration AINODE_CLUSTER_NAME = "defaultCluster" -AINODE_TARGET_CONFIG_NODE_LIST = TEndPoint("127.0.0.1", 10910) +AINODE_TARGET_CONFIG_NODE_LIST = TEndPoint("127.0.0.1", 10710) AINODE_RPC_ADDRESS = "127.0.0.1" -AINODE_RPC_PORT = 20810 +AINODE_RPC_PORT = 10810 AINODE_CLUSTER_INGRESS_ADDRESS = "127.0.0.1" -AINODE_CLUSTER_INGRESS_PORT = 9667 +AINODE_CLUSTER_INGRESS_PORT = 6667 AINODE_CLUSTER_INGRESS_USERNAME = "root" AINODE_CLUSTER_INGRESS_PASSWORD = "root" AINODE_CLUSTER_INGRESS_TIME_ZONE = "UTC+8" diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/executor/ClusterConfigTaskExecutor.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/executor/ClusterConfigTaskExecutor.java index aa5f3034703..3be231b8c10 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/executor/ClusterConfigTaskExecutor.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/executor/ClusterConfigTaskExecutor.java @@ -3397,6 +3397,8 @@ public class ClusterConfigTaskExecutor implements IConfigTaskExecutor { final TShowLoadedModelReq req = new TShowLoadedModelReq(); if (deviceIdList != null) { req.setDeviceIdList(deviceIdList); + } else { + req.setDeviceIdList(new ArrayList<>()); } final TShowLoadedModelResp resp = client.showLoadedModel(req); if (resp.getStatus().getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) { diff --git a/iotdb-protocol/thrift-ainode/src/main/thrift/ainode.thrift b/iotdb-protocol/thrift-ainode/src/main/thrift/ainode.thrift index c53b482ef77..e0680cd29b7 100644 --- a/iotdb-protocol/thrift-ainode/src/main/thrift/ainode.thrift +++ b/iotdb-protocol/thrift-ainode/src/main/thrift/ainode.thrift @@ -112,7 +112,7 @@ struct TShowModelsResp { } struct TShowLoadedModelsReq { - 1: optional list<string> deviceIdList + 1: required list<string> deviceIdList } struct TShowLoadedModelsResp { diff --git a/iotdb-protocol/thrift-confignode/src/main/thrift/confignode.thrift b/iotdb-protocol/thrift-confignode/src/main/thrift/confignode.thrift index 18655a31a11..3df6ad74df7 100644 --- a/iotdb-protocol/thrift-confignode/src/main/thrift/confignode.thrift +++ b/iotdb-protocol/thrift-confignode/src/main/thrift/confignode.thrift @@ -1071,7 +1071,7 @@ struct TShowModelResp { } struct TShowLoadedModelReq { - 1: optional list<string> deviceIdList + 1: required list<string> deviceIdList } struct TShowLoadedModelResp {
