Fixed the NPE caused by multiple errors (#16091)

Caideyipi · web-flow · commit 490aab1341b5 · 2025-08-05T18:27:18.000+08:00
* partial

* fix

* partial

* add-failure-hanlder
diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/cq/CreateCQProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/cq/CreateCQProcedure.java
@@ -136,10 +136,10 @@ private void addCQ(ConfigNodeProcedureEnv env) {
       setNextState(INACTIVE);
     } else if (res.code == TSStatusCode.CQ_ALREADY_EXIST.getStatusCode()) {
       LOGGER.info("Failed to init CQ {} because such cq already exists", req.cqId);
-      setFailure(new ProcedureException(new IoTDBException(res.message, res.code)));
+      setFailure(new ProcedureException(new IoTDBException(res)));
     } else {
       LOGGER.warn("Failed to init CQ {} because of unknown reasons {}", req.cqId, res);
-      setFailure(new ProcedureException(new IoTDBException(res.message, res.code)));
+      setFailure(new ProcedureException(new IoTDBException(res)));
     }
   }
 
diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/SetTTLProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/SetTTLProcedure.java
@@ -97,7 +97,7 @@ private void setConfigNodeTTL(ConfigNodeProcedureEnv env) {
     }
     if (res.code != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
       LOGGER.info("Failed to execute plan {} because {}", plan, res.message);
-      setFailure(new ProcedureException(new IoTDBException(res.message, res.code)));
+      setFailure(new ProcedureException(new IoTDBException(res)));
     } else {
       setNextState(SetTTLState.UPDATE_DATANODE_CACHE);
     }
diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/SetTemplateProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/SetTemplateProcedure.java
@@ -168,9 +168,7 @@ private void validateTemplateExistence(final ConfigNodeProcedureEnv env) {
     if (resp.getStatus().getCode() == TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
       setNextState(SetTemplateState.PRE_SET);
     } else {
-      setFailure(
-          new ProcedureException(
-              new IoTDBException(resp.getStatus().getMessage(), resp.getStatus().getCode())));
+      setFailure(new ProcedureException(new IoTDBException(resp.getStatus())));
     }
   }
 
@@ -193,7 +191,7 @@ private void preSetTemplate(final ConfigNodeProcedureEnv env) {
           templateName,
           templateSetPath,
           status.getMessage());
-      setFailure(new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));
+      setFailure(new ProcedureException(new IoTDBException(status)));
     }
   }
 
@@ -368,7 +366,7 @@ private void commitSetTemplate(final ConfigNodeProcedureEnv env) {
           templateName,
           templateSetPath,
           status.getMessage());
-      setFailure(new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));
+      setFailure(new ProcedureException(new IoTDBException(status)));
     }
   }
 
@@ -470,7 +468,7 @@ private void rollbackPreSet(final ConfigNodeProcedureEnv env) {
           templateName,
           templateSetPath,
           status.getMessage());
-      setFailure(new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));
+      setFailure(new ProcedureException(new IoTDBException(status)));
     }
   }
 
@@ -529,7 +527,7 @@ private void rollbackCommitSet(final ConfigNodeProcedureEnv env) {
           templateName,
           templateSetPath,
           status.getMessage());
-      setFailure(new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));
+      setFailure(new ProcedureException(new IoTDBException(status)));
     }
   }
 
diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/UnsetTemplateProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/UnsetTemplateProcedure.java
@@ -136,7 +136,7 @@ private void constructBlackList(final ConfigNodeProcedureEnv env) {
     if (status.getCode() == TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
       setNextState(UnsetTemplateState.CLEAN_DATANODE_TEMPLATE_CACHE);
     } else {
-      setFailure(new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));
+      setFailure(new ProcedureException(new IoTDBException(status)));
     }
   }
 
@@ -199,7 +199,7 @@ private void unsetTemplate(final ConfigNodeProcedureEnv env) {
             .getClusterSchemaManager()
             .unsetSchemaTemplateInBlackList(template.getId(), path, isGeneratedByPipe);
     if (status.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
-      setFailure(new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));
+      setFailure(new ProcedureException(new IoTDBException(status)));
     }
   }
 
diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/AddTableColumnProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/AddTableColumnProcedure.java
@@ -110,8 +110,7 @@ protected void columnCheck(final ConfigNodeProcedureEnv env) {
                   database, tableName, addedColumnList, this instanceof AddViewColumnProcedure);
       final TSStatus status = result.getLeft();
       if (status.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
-        setFailure(
-            new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));
+        setFailure(new ProcedureException(new IoTDBException(status)));
         return;
       }
       table = result.getRight();
@@ -137,7 +136,7 @@ private void addColumn(final ConfigNodeProcedureEnv env) {
                     : new AddTableColumnPlan(database, tableName, addedColumnList, false),
                 isGeneratedByPipe);
     if (status.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
-      setFailure(new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));
+      setFailure(new ProcedureException(new IoTDBException(status)));
     } else {
       setNextState(AddTableColumnState.COMMIT_RELEASE);
     }
@@ -186,7 +185,7 @@ private void rollbackAddColumn(final ConfigNodeProcedureEnv env) {
                     : new AddTableColumnPlan(database, tableName, addedColumnList, true),
                 isGeneratedByPipe);
     if (status.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
-      setFailure(new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));
+      setFailure(new ProcedureException(new IoTDBException(status)));
     }
   }
 
diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/CreateTableProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/CreateTableProcedure.java
@@ -142,7 +142,7 @@ protected void preCreateTable(final ConfigNodeProcedureEnv env) {
     if (status.getCode() == TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
       setNextState(CreateTableState.PRE_RELEASE);
     } else {
-      setFailure(new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));
+      setFailure(new ProcedureException(new IoTDBException(status)));
     }
   }
 
@@ -175,7 +175,7 @@ private void commitCreateTable(final ConfigNodeProcedureEnv env) {
     if (status.getCode() == TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
       setNextState(CreateTableState.COMMIT_RELEASE);
     } else {
-      setFailure(new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));
+      setFailure(new ProcedureException(new IoTDBException(status)));
     }
   }
 
@@ -225,7 +225,7 @@ protected void rollbackCreate(final ConfigNodeProcedureEnv env) {
             new RollbackCreateTablePlan(database, table.getTableName()), env, LOGGER);
     if (status.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
       LOGGER.warn("Failed to rollback table creation {}.{}", database, table.getTableName());
-      setFailure(new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));
+      setFailure(new ProcedureException(new IoTDBException(status)));
     }
   }
 
diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/DropTableColumnProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/DropTableColumnProcedure.java
@@ -142,7 +142,7 @@ private void checkAndPreDeleteColumn(final ConfigNodeProcedureEnv env) {
       isAttributeColumn = status.isSetMessage();
       setNextState(DropTableColumnState.INVALIDATE_CACHE);
     } else {
-      setFailure(new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));
+      setFailure(new ProcedureException(new IoTDBException(status)));
     }
   }
 
@@ -216,7 +216,7 @@ private void dropColumn(final ConfigNodeProcedureEnv env) {
                     : new CommitDeleteColumnPlan(database, tableName, columnName),
                 isGeneratedByPipe);
     if (status.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
-      setFailure(new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));
+      setFailure(new ProcedureException(new IoTDBException(status)));
     }
   }
 
diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/DropTableProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/DropTableProcedure.java
@@ -125,7 +125,7 @@ private void checkAndPreDeleteTable(final ConfigNodeProcedureEnv env) {
     if (status.getCode() == TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
       setNextState(DropTableState.INVALIDATE_CACHE);
     } else {
-      setFailure(new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));
+      setFailure(new ProcedureException(new IoTDBException(status)));
     }
   }
 
@@ -201,7 +201,7 @@ private void dropTable(final ConfigNodeProcedureEnv env) {
                     : new CommitDeleteTablePlan(database, tableName),
                 isGeneratedByPipe);
     if (status.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
-      setFailure(new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));
+      setFailure(new ProcedureException(new IoTDBException(status)));
     }
   }
 
diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/RenameTableColumnProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/RenameTableColumnProcedure.java
@@ -113,8 +113,7 @@ private void columnCheck(final ConfigNodeProcedureEnv env) {
                   database, tableName, oldName, newName, this instanceof RenameViewColumnProcedure);
       final TSStatus status = result.getLeft();
       if (status.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
-        setFailure(
-            new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));
+        setFailure(new ProcedureException(new IoTDBException(status)));
         return;
       }
       table = result.getRight();
@@ -140,7 +139,7 @@ private void renameColumn(final ConfigNodeProcedureEnv env) {
                     : new RenameTableColumnPlan(database, tableName, oldName, newName),
                 isGeneratedByPipe);
     if (status.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
-      setFailure(new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));
+      setFailure(new ProcedureException(new IoTDBException(status)));
     } else {
       setNextState(RenameTableColumnState.COMMIT_RELEASE);
     }
@@ -184,7 +183,7 @@ private void rollbackRenameColumn(final ConfigNodeProcedureEnv env) {
                 new RenameTableColumnPlan(database, tableName, newName, oldName),
                 isGeneratedByPipe);
     if (status.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
-      setFailure(new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));
+      setFailure(new ProcedureException(new IoTDBException(status)));
     }
   }
 
diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/RenameTableProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/RenameTableProcedure.java
@@ -106,8 +106,7 @@ private void tableCheck(final ConfigNodeProcedureEnv env) {
                   database, tableName, newName, this instanceof RenameViewProcedure);
       final TSStatus status = result.getLeft();
       if (status.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
-        setFailure(
-            new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));
+        setFailure(new ProcedureException(new IoTDBException(status)));
         return;
       }
       table = result.getRight();
@@ -133,7 +132,7 @@ private void renameTable(final ConfigNodeProcedureEnv env) {
                     : new RenameTablePlan(database, tableName, newName),
                 isGeneratedByPipe);
     if (status.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
-      setFailure(new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));
+      setFailure(new ProcedureException(new IoTDBException(status)));
     } else {
       setNextState(RenameTableState.COMMIT_RELEASE);
     }
@@ -175,7 +174,7 @@ private void rollbackRenameTable(final ConfigNodeProcedureEnv env) {
                     : new RenameTablePlan(database, newName, tableName),
                 isGeneratedByPipe);
     if (status.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
-      setFailure(new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));
+      setFailure(new ProcedureException(new IoTDBException(status)));
     }
   }
 
diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/SetTablePropertiesProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/SetTablePropertiesProcedure.java
@@ -130,8 +130,7 @@ private void validateTable(final ConfigNodeProcedureEnv env) {
                   this instanceof SetViewPropertiesProcedure);
       final TSStatus status = result.getLeft();
       if (status.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
-        setFailure(
-            new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));
+        setFailure(new ProcedureException(new IoTDBException(status)));
         return;
       }
       table = result.getRight();
@@ -157,7 +156,7 @@ private void setProperties(final ConfigNodeProcedureEnv env) {
                     : new SetTablePropertiesPlan(database, tableName, updatedProperties),
                 isGeneratedByPipe);
     if (status.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
-      setFailure(new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));
+      setFailure(new ProcedureException(new IoTDBException(status)));
     } else {
       setNextState(COMMIT_RELEASE);
     }
@@ -207,7 +206,7 @@ private void rollbackSetProperties(final ConfigNodeProcedureEnv env) {
                 new SetTablePropertiesPlan(database, tableName, originalProperties),
                 isGeneratedByPipe);
     if (status.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
-      setFailure(new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));
+      setFailure(new ProcedureException(new IoTDBException(status)));
     }
   }
 
diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/view/AddViewColumnProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/view/AddViewColumnProcedure.java
@@ -76,8 +76,7 @@ protected void columnCheck(final ConfigNodeProcedureEnv env) {
           new TreeDeviceViewFieldDetector(env.getConfigManager(), table, fields2Detect)
               .detectMissingFieldTypes();
       if (status.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
-        setFailure(
-            new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));
+        setFailure(new ProcedureException(new IoTDBException(status)));
       }
     }
   }
diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/view/CreateTableViewProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/view/CreateTableViewProcedure.java
@@ -111,7 +111,7 @@ protected void checkTableExistence(final ConfigNodeProcedureEnv env) {
         new TreeDeviceViewFieldDetector(env.getConfigManager(), table, null)
             .detectMissingFieldTypes();
     if (status.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
-      setFailure(new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));
+      setFailure(new ProcedureException(new IoTDBException(status)));
     }
   }
 
@@ -123,7 +123,7 @@ protected void preCreateTable(final ConfigNodeProcedureEnv env) {
     if (status.getCode() == TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
       setNextState(CreateTableState.PRE_RELEASE);
     } else {
-      setFailure(new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));
+      setFailure(new ProcedureException(new IoTDBException(status)));
     }
   }
 
@@ -138,7 +138,7 @@ protected void rollbackCreate(final ConfigNodeProcedureEnv env) {
             new PreCreateTableViewPlan(database, oldView, oldStatus), env, LOGGER);
     if (status.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
       LOGGER.warn("Failed to rollback table creation {}.{}", database, table.getTableName());
-      setFailure(new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));
+      setFailure(new ProcedureException(new IoTDBException(status)));
     }
   }
 
diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/sync/AuthOperationProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/sync/AuthOperationProcedure.java
@@ -162,7 +162,7 @@ private void writePlan(ConfigNodeProcedureEnv env) {
           "Execute auth plan {} success. To invalidate datanodes: {}", plan, dataNodesToInvalid);
     } else {
       LOGGER.info("Failed to execute plan {} because {}", plan, res.message);
-      setFailure(new ProcedureException(new IoTDBException(res.message, res.code)));
+      setFailure(new ProcedureException(new IoTDBException(res)));
     }
   }
 
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/auth/ClusterAuthorityFetcher.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/auth/ClusterAuthorityFetcher.java
@@ -378,7 +378,7 @@ private SettableFuture<ConfigTaskResult> operatePermissionInternal(
               : configNodeClient.operatePermission(
                   statementToAuthorizerReq((AuthorStatement) plan));
       if (TSStatusCode.SUCCESS_STATUS.getStatusCode() != tsStatus.getCode()) {
-        future.setException(new IoTDBException(tsStatus.message, tsStatus.code));
+        future.setException(new IoTDBException(tsStatus));
       } else {
         onOperatePermissionSuccess(plan);
         future.set(new ConfigTaskResult(TSStatusCode.SUCCESS_STATUS));
@@ -437,8 +437,7 @@ private SettableFuture<ConfigTaskResult> queryPermissionInternal(
       LOGGER.error(CONNECTERROR);
       authorizerResp.setStatus(
           RpcUtils.getStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR, CONNECTERROR));
-      future.setException(
-          new IoTDBException(authorizerResp.getStatus().message, authorizerResp.getStatus().code));
+      future.setException(new IoTDBException(authorizerResp.getStatus()));
     }
     return future;
   }
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/QueryStateMachine.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/QueryStateMachine.java
@@ -149,7 +149,7 @@ public String getFailureMessage() {
   public Throwable getFailureException() {
     Throwable throwable = failureException.get();
     if (throwable == null) {
-      return new IoTDBException(getFailureStatus().getMessage(), getFailureStatus().code);
+      return new IoTDBException(getFailureStatus());
     } else {
       return throwable;
     }
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/partition/PartitionCache.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/partition/PartitionCache.java
@@ -315,8 +315,7 @@ private void createDatabaseAndUpdateCache(
                           userName, PrivilegeType.MANAGE_DATABASE),
                       PrivilegeType.MANAGE_DATABASE);
               if (status.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
-                throw new RuntimeException(
-                    new IoTDBException(status.getMessage(), status.getCode()));
+                throw new RuntimeException(new IoTDBException(status));
               }
             }
           } finally {
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/schema/AutoCreateSchemaExecutor.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/schema/AutoCreateSchemaExecutor.java
@@ -549,7 +549,7 @@ private void internalActivateTemplate(PartialPath devicePath, MPPQueryContext co
     status = executionResult.status;
     if (status.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()
         && status.getCode() != TSStatusCode.TEMPLATE_IS_IN_USE.getStatusCode()) {
-      throw new SemanticException(new IoTDBException(status.getMessage(), status.getCode()));
+      throw new SemanticException(new IoTDBException(status));
     }
   }
 
@@ -581,7 +581,7 @@ private void internalActivateTemplate(
         throw new SemanticException(new MetadataException(String.join("; ", failedActivationSet)));
       }
     } else {
-      throw new SemanticException(new IoTDBException(status.getMessage(), status.getCode()));
+      throw new SemanticException(new IoTDBException(status));
     }
   }
 
@@ -660,7 +660,7 @@ private void internalExtendTemplate(
     if (status.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()
         && status.getCode()
             != TSStatusCode.MEASUREMENT_ALREADY_EXISTS_IN_TEMPLATE.getStatusCode()) {
-      throw new SemanticException(new IoTDBException(status.getMessage(), status.getCode()));
+      throw new SemanticException(new IoTDBException(status));
     }
   }
 }
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/QueryExecution.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/QueryExecution.java
@@ -464,7 +464,7 @@ private void dealWithException(Throwable t) throws IoTDBException {
     stateMachine.transitionToFailed(t);
     TSStatus status = stateMachine.getFailureStatus();
     if (status != null) {
-      throw new IoTDBException(status.getMessage(), status.code);
+      throw new IoTDBException(status);
     } else {
       Throwable rootCause = stateMachine.getFailureException();
       if (rootCause != null) {
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/ConfigExecution.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/ConfigExecution.java
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/ConfigTaskResult.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/ConfigTaskResult.java
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
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/template/ClusterTemplateManager.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/template/ClusterTemplateManager.java
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/ErrorHandlingUtils.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/ErrorHandlingUtils.java
diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/IoTDBException.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/IoTDBException.java
diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/IoTDBRuntimeException.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/IoTDBRuntimeException.java

Original file line number	Diff line number	Diff line change
`@@ -136,10 +136,10 @@ private void addCQ(ConfigNodeProcedureEnv env) {`
`136`	`136`	`setNextState(INACTIVE);`
`137`	`137`	`} else if (res.code == TSStatusCode.CQ_ALREADY_EXIST.getStatusCode()) {`
`138`	`138`	`LOGGER.info("Failed to init CQ {} because such cq already exists", req.cqId);`
`139`		`- setFailure(new ProcedureException(new IoTDBException(res.message, res.code)));`
	`139`	`+ setFailure(new ProcedureException(new IoTDBException(res)));`
`140`	`140`	`} else {`
`141`	`141`	`LOGGER.warn("Failed to init CQ {} because of unknown reasons {}", req.cqId, res);`
`142`		`- setFailure(new ProcedureException(new IoTDBException(res.message, res.code)));`
	`142`	`+ setFailure(new ProcedureException(new IoTDBException(res)));`
`143`	`143`	`}`
`144`	`144`	`}`
`145`	`145`
Original file line number	Diff line number	Diff line change
`@@ -97,7 +97,7 @@ private void setConfigNodeTTL(ConfigNodeProcedureEnv env) {`
`97`	`97`	`}`
`98`	`98`	`if (res.code != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {`
`99`	`99`	`LOGGER.info("Failed to execute plan {} because {}", plan, res.message);`
`100`		`- setFailure(new ProcedureException(new IoTDBException(res.message, res.code)));`
	`100`	`+ setFailure(new ProcedureException(new IoTDBException(res)));`
`101`	`101`	`} else {`
`102`	`102`	`setNextState(SetTTLState.UPDATE_DATANODE_CACHE);`
`103`	`103`	`}`
Original file line number	Diff line number	Diff line change
`@@ -168,9 +168,7 @@ private void validateTemplateExistence(final ConfigNodeProcedureEnv env) {`
`168`	`168`	`if (resp.getStatus().getCode() == TSStatusCode.SUCCESS_STATUS.getStatusCode()) {`
`169`	`169`	`setNextState(SetTemplateState.PRE_SET);`
`170`	`170`	`} else {`
`171`		`- setFailure(`
`172`		`- new ProcedureException(`
`173`		`- new IoTDBException(resp.getStatus().getMessage(), resp.getStatus().getCode())));`
	`171`	`+ setFailure(new ProcedureException(new IoTDBException(resp.getStatus())));`
`174`	`172`	`}`
`175`	`173`	`}`
`176`	`174`
`@@ -193,7 +191,7 @@ private void preSetTemplate(final ConfigNodeProcedureEnv env) {`
`193`	`191`	`templateName,`
`194`	`192`	`templateSetPath,`
`195`	`193`	`status.getMessage());`
`196`		`- setFailure(new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));`
	`194`	`+ setFailure(new ProcedureException(new IoTDBException(status)));`
`197`	`195`	`}`
`198`	`196`	`}`
`199`	`197`
`@@ -368,7 +366,7 @@ private void commitSetTemplate(final ConfigNodeProcedureEnv env) {`
`368`	`366`	`templateName,`
`369`	`367`	`templateSetPath,`
`370`	`368`	`status.getMessage());`
`371`		`- setFailure(new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));`
	`369`	`+ setFailure(new ProcedureException(new IoTDBException(status)));`
`372`	`370`	`}`
`373`	`371`	`}`
`374`	`372`
`@@ -470,7 +468,7 @@ private void rollbackPreSet(final ConfigNodeProcedureEnv env) {`
`470`	`468`	`templateName,`
`471`	`469`	`templateSetPath,`
`472`	`470`	`status.getMessage());`
`473`		`- setFailure(new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));`
	`471`	`+ setFailure(new ProcedureException(new IoTDBException(status)));`
`474`	`472`	`}`
`475`	`473`	`}`
`476`	`474`
`@@ -529,7 +527,7 @@ private void rollbackCommitSet(final ConfigNodeProcedureEnv env) {`
`529`	`527`	`templateName,`
`530`	`528`	`templateSetPath,`
`531`	`529`	`status.getMessage());`
`532`		`- setFailure(new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));`
	`530`	`+ setFailure(new ProcedureException(new IoTDBException(status)));`
`533`	`531`	`}`
`534`	`532`	`}`
`535`	`533`
Original file line number	Diff line number	Diff line change
`@@ -136,7 +136,7 @@ private void constructBlackList(final ConfigNodeProcedureEnv env) {`
`136`	`136`	`if (status.getCode() == TSStatusCode.SUCCESS_STATUS.getStatusCode()) {`
`137`	`137`	`setNextState(UnsetTemplateState.CLEAN_DATANODE_TEMPLATE_CACHE);`
`138`	`138`	`} else {`
`139`		`- setFailure(new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));`
	`139`	`+ setFailure(new ProcedureException(new IoTDBException(status)));`
`140`	`140`	`}`
`141`	`141`	`}`
`142`	`142`
`@@ -199,7 +199,7 @@ private void unsetTemplate(final ConfigNodeProcedureEnv env) {`
`199`	`199`	`.getClusterSchemaManager()`
`200`	`200`	`.unsetSchemaTemplateInBlackList(template.getId(), path, isGeneratedByPipe);`
`201`	`201`	`if (status.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {`
`202`		`- setFailure(new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));`
	`202`	`+ setFailure(new ProcedureException(new IoTDBException(status)));`
`203`	`203`	`}`
`204`	`204`	`}`
`205`	`205`
Original file line number	Diff line number	Diff line change
`@@ -142,7 +142,7 @@ protected void preCreateTable(final ConfigNodeProcedureEnv env) {`
`142`	`142`	`if (status.getCode() == TSStatusCode.SUCCESS_STATUS.getStatusCode()) {`
`143`	`143`	`setNextState(CreateTableState.PRE_RELEASE);`
`144`	`144`	`} else {`
`145`		`- setFailure(new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));`
	`145`	`+ setFailure(new ProcedureException(new IoTDBException(status)));`
`146`	`146`	`}`
`147`	`147`	`}`
`148`	`148`
`@@ -175,7 +175,7 @@ private void commitCreateTable(final ConfigNodeProcedureEnv env) {`
`175`	`175`	`if (status.getCode() == TSStatusCode.SUCCESS_STATUS.getStatusCode()) {`
`176`	`176`	`setNextState(CreateTableState.COMMIT_RELEASE);`
`177`	`177`	`} else {`
`178`		`- setFailure(new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));`
	`178`	`+ setFailure(new ProcedureException(new IoTDBException(status)));`
`179`	`179`	`}`
`180`	`180`	`}`
`181`	`181`
`@@ -225,7 +225,7 @@ protected void rollbackCreate(final ConfigNodeProcedureEnv env) {`
`225`	`225`	`new RollbackCreateTablePlan(database, table.getTableName()), env, LOGGER);`
`226`	`226`	`if (status.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {`
`227`	`227`	`LOGGER.warn("Failed to rollback table creation {}.{}", database, table.getTableName());`
`228`		`- setFailure(new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));`
	`228`	`+ setFailure(new ProcedureException(new IoTDBException(status)));`
`229`	`229`	`}`
`230`	`230`	`}`
`231`	`231`
Original file line number	Diff line number	Diff line change
`@@ -142,7 +142,7 @@ private void checkAndPreDeleteColumn(final ConfigNodeProcedureEnv env) {`
`142`	`142`	`isAttributeColumn = status.isSetMessage();`
`143`	`143`	`setNextState(DropTableColumnState.INVALIDATE_CACHE);`
`144`	`144`	`} else {`
`145`		`- setFailure(new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));`
	`145`	`+ setFailure(new ProcedureException(new IoTDBException(status)));`
`146`	`146`	`}`
`147`	`147`	`}`
`148`	`148`
`@@ -216,7 +216,7 @@ private void dropColumn(final ConfigNodeProcedureEnv env) {`
`216`	`216`	`: new CommitDeleteColumnPlan(database, tableName, columnName),`
`217`	`217`	`isGeneratedByPipe);`
`218`	`218`	`if (status.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {`
`219`		`- setFailure(new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));`
	`219`	`+ setFailure(new ProcedureException(new IoTDBException(status)));`
`220`	`220`	`}`
`221`	`221`	`}`
`222`	`222`
Original file line number	Diff line number	Diff line change
`@@ -125,7 +125,7 @@ private void checkAndPreDeleteTable(final ConfigNodeProcedureEnv env) {`
`125`	`125`	`if (status.getCode() == TSStatusCode.SUCCESS_STATUS.getStatusCode()) {`
`126`	`126`	`setNextState(DropTableState.INVALIDATE_CACHE);`
`127`	`127`	`} else {`
`128`		`- setFailure(new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));`
	`128`	`+ setFailure(new ProcedureException(new IoTDBException(status)));`
`129`	`129`	`}`
`130`	`130`	`}`
`131`	`131`
`@@ -201,7 +201,7 @@ private void dropTable(final ConfigNodeProcedureEnv env) {`
`201`	`201`	`: new CommitDeleteTablePlan(database, tableName),`
`202`	`202`	`isGeneratedByPipe);`
`203`	`203`	`if (status.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {`
`204`		`- setFailure(new ProcedureException(new IoTDBException(status.getMessage(), status.getCode())));`
	`204`	`+ setFailure(new ProcedureException(new IoTDBException(status)));`
`205`	`205`	`}`
`206`	`206`	`}`
`207`	`207`