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()));

Reply via email to