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;
