(iotdb) branch master updated: Fix the error message of ConfigExecution (#16680)

[jackietien]

This is an automated email from the ASF dual-hosted git repository.

jackietien 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 c406a81f53c Fix the error message of ConfigExecution (#16680)
c406a81f53c is described below

commit c406a81f53c050c7b497af335a2bd72f465436e0
Author: shuwenwei <55970239+shuwen...@users.noreply.github.com>
AuthorDate: Fri Nov 7 17:09:09 2025 +0800

    Fix the error message of ConfigExecution (#16680)
---
 .../plan/execution/config/ConfigExecution.java           | 16 +++++++++-------
 1 file changed, 9 insertions(+), 7 deletions(-)

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
index 1ae57fe38d5..1880924f297 100644
--- 
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
@@ -166,28 +166,30 @@ public class ConfigExecution implements IQueryExecution {
     if (cause instanceof IoTDBException) {
       if (Objects.nonNull(((IoTDBException) cause).getStatus())) {
         status = ((IoTDBException) cause).getStatus();
+        errorCode = status.getCode();
       } else {
         errorCode = ((IoTDBException) cause).getErrorCode();
       }
     } else if (cause instanceof IoTDBRuntimeException) {
       if (Objects.nonNull(((IoTDBRuntimeException) cause).getStatus())) {
         status = ((IoTDBRuntimeException) cause).getStatus();
+        errorCode = status.getCode();
       } else {
         errorCode = ((IoTDBRuntimeException) cause).getErrorCode();
       }
     }
-    if (Objects.nonNull(status) && isUserException(status)
-        || !userExceptionCodes.contains(errorCode)) {
-      LOGGER.warn(
-          "Failures happened during running ConfigExecution when executing 
{}.",
-          Objects.nonNull(task) ? task.getClass().getSimpleName() : null,
-          cause);
-    } else {
+    if ((Objects.nonNull(status) && isUserException(status))
+        || userExceptionCodes.contains(errorCode)) {
       LOGGER.info(
           "Failures happened during running ConfigExecution when executing {}, 
message: {}, status: {}",
           Objects.nonNull(task) ? task.getClass().getSimpleName() : null,
           cause.getMessage(),
           errorCode);
+    } else {
+      LOGGER.warn(
+          "Failures happened during running ConfigExecution when executing 
{}.",
+          Objects.nonNull(task) ? task.getClass().getSimpleName() : null,
+          cause);
     }
     stateMachine.transitionToFailed(cause);
     final ConfigTaskResult result;