This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch ty/PathAlreadyExist in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit b91459047a0cbc6cdcf3ce9c5c16d1a26717d7dc Author: JackieTien97 <[email protected]> AuthorDate: Tue Jan 2 20:12:19 2024 +0800 Print Exception only when encountering unexpected TSStatus --- .../db/queryengine/execution/executor/RegionWriteExecutor.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/executor/RegionWriteExecutor.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/executor/RegionWriteExecutor.java index 7c6348fdbb4..eba3e73f42f 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/executor/RegionWriteExecutor.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/executor/RegionWriteExecutor.java @@ -574,7 +574,11 @@ public class RegionWriteExecutor { ((MeasurementAlreadyExistException) metadataException) .getMeasurementPath()))); } else { - LOGGER.warn(METADATA_ERROR_MSG, metadataException); + int errorCode = metadataException.getErrorCode(); + if (errorCode != TSStatusCode.PATH_ALREADY_EXIST.getStatusCode() + || errorCode != TSStatusCode.ALIAS_ALREADY_EXIST.getStatusCode()) { + LOGGER.warn(METADATA_ERROR_MSG, metadataException); + } failingStatus.add( RpcUtils.getStatus( metadataException.getErrorCode(), metadataException.getMessage()));
