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

jackietien pushed a commit to branch force_ci/object_type
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit 96d4eae4e151b4ce1f1578b4b762bd84ebc5772d
Author: shuwenwei <[email protected]>
AuthorDate: Fri Nov 7 17:09:09 2025 +0800

    Fix the error message of ConfigExecution (#16680)
    
    (cherry picked from commit c406a81f53c050c7b497af335a2bd72f465436e0)
---
 .../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;

Reply via email to