You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by yo...@apache.org on 2025/09/19 06:39:31 UTC
(iotdb) branch master updated: Avoid NPE for show variables task (#16444)
This is an automated email from the ASF dual-hosted git repository.
yongzao pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new 5e7a8c763a9 Avoid NPE for show variables task (#16444)
5e7a8c763a9 is described below
commit 5e7a8c763a91cbe414b20c0f3a6000138e53d280
Author: Yongzao <yo...@apache.org>
AuthorDate: Fri Sep 19 14:39:25 2025 +0800
Avoid NPE for show variables task (#16444)
---
.../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