This is an automated email from the ASF dual-hosted git repository.
tanxinyu 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 f920cdc8e86 Print Exception only when encountering unexpected TSStatus
(#11827)
f920cdc8e86 is described below
commit f920cdc8e861b0809d98feba7f8eac87d106e6ea
Author: Jackie Tien <[email protected]>
AuthorDate: Wed Jan 3 12:23:16 2024 +0800
Print Exception only when encountering unexpected TSStatus (#11827)
---
.../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()));