This is an automated email from the ASF dual-hosted git repository. yongzao pushed a commit to branch fix-show-variable-NPE in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 1907369aab57d6a4a1e048ef2b621252fbfafb84 Author: Yongzao <[email protected]> AuthorDate: Fri Sep 19 11:49:59 2025 +0800 Update ClusterConfigTaskExecutor.java --- .../plan/execution/config/executor/ClusterConfigTaskExecutor.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) 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 4df8a6a4f71..9605e38f1e3 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 @@ -1527,7 +1527,13 @@ public class ClusterConfigTaskExecutor implements IConfigTaskExecutor { CONFIG_NODE_CLIENT_MANAGER.borrowClient(ConfigNodeInfo.CONFIG_REGION_ID)) { showVariablesResp = client.showVariables(); } catch (ClientManagerException | TException e) { - future.setException(e); + if (showVariablesResp.getStatus().getCode() + == TSStatusCode.REDIRECTION_RECOMMEND.getStatusCode()) { + future.setException(new TException(MSG_RECONNECTION_FAIL)); + } else { + future.setException(e); + } + return future; } // build TSBlock
