You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2024/01/02 12:12:31 UTC
(iotdb) branch ty/PathAlreadyExist created (now b91459047a0)
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch ty/PathAlreadyExist
in repository https://gitbox.apache.org/repos/asf/iotdb.git
at b91459047a0 Print Exception only when encountering unexpected TSStatus
This branch includes the following new commits:
new b91459047a0 Print Exception only when encountering unexpected TSStatus
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
(iotdb) 01/01: Print Exception only when encountering unexpected TSStatus
Posted by ja...@apache.org.
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 <ja...@gmail.com>
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()));