You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by qi...@apache.org on 2022/11/14 15:42:37 UTC
[iotdb] 01/02: fix some status code
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a commit to branch fix_statuscode
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit d22136a564e6729cd244817044ef059a82c828f1
Author: qiaojialin <64...@qq.com>
AuthorDate: Mon Nov 14 17:24:01 2022 +0800
fix some status code
---
.../confignode/manager/ClusterSchemaManager.java | 4 +-
.../iotdb/confignode/manager/ConfigManager.java | 2 +-
.../iotdb/confignode/manager/SyncManager.java | 4 +-
.../manager/partition/PartitionManager.java | 2 +-
.../persistence/schema/ClusterSchemaInfo.java | 22 ++--
.../persistence/sync/ClusterSyncInfo.java | 2 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 2 +-
docs/UserGuide/API/Status-Codes.md | 31 ++++--
docs/zh/UserGuide/API/Status-Codes.md | 34 ++++--
.../apache/iotdb/db/integration/IoTDBTtlIT.java | 14 +--
.../commons/exception/sync/PipeSinkException.java | 4 +-
.../apache/iotdb/commons/utils/StatusUtils.java | 115 +++++++++------------
.../apache/iotdb/db/engine/StorageEngineV2.java | 4 +-
.../iotdb/db/exception/DataRegionException.java | 4 +-
.../exception/metadata/PathNotExistException.java | 6 +-
.../metadata/StorageGroupNotSetException.java | 4 +-
.../template/TemplateImcompatibeException.java | 4 +-
.../iotdb/db/localconfignode/LocalConfigNode.java | 4 +-
.../executor/StandaloneConfigTaskExecutor.java | 2 +-
.../iotdb/db/sync/common/LocalSyncInfoFetcher.java | 2 +-
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 6 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 18 ++--
22 files changed, 150 insertions(+), 140 deletions(-)
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/manager/ClusterSchemaManager.java b/confignode/src/main/java/org/apache/iotdb/confignode/manager/ClusterSchemaManager.java
index 227305330e..dffe4df3ec 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/manager/ClusterSchemaManager.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/manager/ClusterSchemaManager.java
@@ -193,7 +193,7 @@ public class ClusterSchemaManager {
// Return immediately if some StorageGroups doesn't exist
return new TShowStorageGroupResp()
.setStatus(
- new TSStatus(TSStatusCode.STORAGE_GROUP_NOT_EXIST.getStatusCode())
+ new TSStatus(TSStatusCode.DATABASE_NOT_EXIST.getStatusCode())
.setMessage(e.getMessage()));
}
@@ -218,7 +218,7 @@ public class ClusterSchemaManager {
if (storageSchemaMap.isEmpty()) {
return RpcUtils.getStatus(
- TSStatusCode.STORAGE_GROUP_NOT_EXIST,
+ TSStatusCode.DATABASE_NOT_EXIST,
"Path [" + new PartialPath(setTTLPlan.getStorageGroupPathPattern()) + "] does not exist");
}
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java b/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java
index 2baaf0a600..010979a52f 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java
@@ -435,7 +435,7 @@ public class ConfigManager implements IManager {
getClusterSchemaManager().getMatchedStorageGroupSchemasByName(deletedPaths);
if (deleteStorageSchemaMap.isEmpty()) {
return RpcUtils.getStatus(
- TSStatusCode.TIMESERIES_NOT_EXIST.getStatusCode(),
+ TSStatusCode.PATH_NOT_EXIST_ERROR.getStatusCode(),
String.format("Path %s does not exist", Arrays.toString(deletedPaths.toArray())));
}
ArrayList<TStorageGroupSchema> parsedDeleteStorageGroups =
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/manager/SyncManager.java b/confignode/src/main/java/org/apache/iotdb/confignode/manager/SyncManager.java
index 88c3b31449..e57e1ef089 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/manager/SyncManager.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/manager/SyncManager.java
@@ -95,7 +95,7 @@ public class SyncManager {
return getConsensusManager().write(plan).getStatus();
} catch (PipeSinkException e) {
LOGGER.error(e.getMessage());
- return new TSStatus(TSStatusCode.PIPESINK_ERROR.getStatusCode()).setMessage(e.getMessage());
+ return new TSStatus(TSStatusCode.CREATE_PIPE_SINK_ERROR.getStatusCode()).setMessage(e.getMessage());
}
}
@@ -105,7 +105,7 @@ public class SyncManager {
return getConsensusManager().write(plan).getStatus();
} catch (PipeSinkException e) {
LOGGER.error(e.getMessage());
- return new TSStatus(TSStatusCode.PIPESINK_ERROR.getStatusCode()).setMessage(e.getMessage());
+ return new TSStatus(TSStatusCode.CREATE_PIPE_SINK_ERROR.getStatusCode()).setMessage(e.getMessage());
}
}
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/PartitionManager.java b/confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/PartitionManager.java
index f130f92894..920551cc51 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/PartitionManager.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/PartitionManager.java
@@ -402,7 +402,7 @@ public class PartitionManager {
} catch (StorageGroupNotExistsException e) {
String prompt = "ConfigNode failed to extend Region because some StorageGroup doesn't exist.";
LOGGER.error(prompt);
- result.setCode(TSStatusCode.STORAGE_GROUP_NOT_EXIST.getStatusCode());
+ result.setCode(TSStatusCode.DATABASE_NOT_EXIST.getStatusCode());
result.setMessage(prompt);
}
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/persistence/schema/ClusterSchemaInfo.java b/confignode/src/main/java/org/apache/iotdb/confignode/persistence/schema/ClusterSchemaInfo.java
index 9d1163a433..1b93dce687 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/persistence/schema/ClusterSchemaInfo.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/persistence/schema/ClusterSchemaInfo.java
@@ -184,7 +184,7 @@ public class ClusterSchemaInfo implements SnapshotProcessor {
} catch (MetadataException e) {
LOGGER.error("Error StorageGroup name", e);
result.setStatus(
- new TSStatus(TSStatusCode.STORAGE_GROUP_NOT_EXIST.getStatusCode())
+ new TSStatus(TSStatusCode.DATABASE_NOT_EXIST.getStatusCode())
.setMessage("Error StorageGroup name: " + e.getMessage()));
} finally {
storageGroupReadWriteLock.readLock().unlock();
@@ -210,7 +210,7 @@ public class ClusterSchemaInfo implements SnapshotProcessor {
} catch (MetadataException e) {
LOGGER.error("Error StorageGroup name", e);
result.setStatus(
- new TSStatus(TSStatusCode.STORAGE_GROUP_NOT_EXIST.getStatusCode())
+ new TSStatus(TSStatusCode.DATABASE_NOT_EXIST.getStatusCode())
.setMessage("Error StorageGroup name: " + e.getMessage()));
} finally {
storageGroupReadWriteLock.readLock().unlock();
@@ -233,13 +233,13 @@ public class ClusterSchemaInfo implements SnapshotProcessor {
}
result.setCode(TSStatusCode.SUCCESS_STATUS.getStatusCode());
} else {
- result.setCode(TSStatusCode.STORAGE_GROUP_NOT_EXIST.getStatusCode());
+ result.setCode(TSStatusCode.DATABASE_NOT_EXIST.getStatusCode());
result.setMessage("StorageGroup does not exist");
}
} catch (MetadataException e) {
LOGGER.error("Error StorageGroup name", e);
result
- .setCode(TSStatusCode.STORAGE_GROUP_NOT_EXIST.getStatusCode())
+ .setCode(TSStatusCode.DATABASE_NOT_EXIST.getStatusCode())
.setMessage("Error StorageGroupName");
} finally {
storageGroupReadWriteLock.writeLock().unlock();
@@ -259,12 +259,12 @@ public class ClusterSchemaInfo implements SnapshotProcessor {
.setSchemaReplicationFactor(plan.getSchemaReplicationFactor());
result.setCode(TSStatusCode.SUCCESS_STATUS.getStatusCode());
} else {
- result.setCode(TSStatusCode.STORAGE_GROUP_NOT_EXIST.getStatusCode());
+ result.setCode(TSStatusCode.DATABASE_NOT_EXIST.getStatusCode());
}
} catch (MetadataException e) {
LOGGER.error("Error StorageGroup name", e);
result
- .setCode(TSStatusCode.STORAGE_GROUP_NOT_EXIST.getStatusCode())
+ .setCode(TSStatusCode.DATABASE_NOT_EXIST.getStatusCode())
.setMessage("Error StorageGroupName");
} finally {
storageGroupReadWriteLock.writeLock().unlock();
@@ -284,12 +284,12 @@ public class ClusterSchemaInfo implements SnapshotProcessor {
.setDataReplicationFactor(plan.getDataReplicationFactor());
result.setCode(TSStatusCode.SUCCESS_STATUS.getStatusCode());
} else {
- result.setCode(TSStatusCode.STORAGE_GROUP_NOT_EXIST.getStatusCode());
+ result.setCode(TSStatusCode.DATABASE_NOT_EXIST.getStatusCode());
}
} catch (MetadataException e) {
LOGGER.error("Error StorageGroup name", e);
result
- .setCode(TSStatusCode.STORAGE_GROUP_NOT_EXIST.getStatusCode())
+ .setCode(TSStatusCode.DATABASE_NOT_EXIST.getStatusCode())
.setMessage("Error StorageGroupName");
} finally {
storageGroupReadWriteLock.writeLock().unlock();
@@ -309,12 +309,12 @@ public class ClusterSchemaInfo implements SnapshotProcessor {
.setTimePartitionInterval(plan.getTimePartitionInterval());
result.setCode(TSStatusCode.SUCCESS_STATUS.getStatusCode());
} else {
- result.setCode(TSStatusCode.STORAGE_GROUP_NOT_EXIST.getStatusCode());
+ result.setCode(TSStatusCode.DATABASE_NOT_EXIST.getStatusCode());
}
} catch (MetadataException e) {
LOGGER.error("Error StorageGroup name", e);
result
- .setCode(TSStatusCode.STORAGE_GROUP_NOT_EXIST.getStatusCode())
+ .setCode(TSStatusCode.DATABASE_NOT_EXIST.getStatusCode())
.setMessage("Error StorageGroupName");
} finally {
storageGroupReadWriteLock.writeLock().unlock();
@@ -343,7 +343,7 @@ public class ClusterSchemaInfo implements SnapshotProcessor {
result.setCode(TSStatusCode.SUCCESS_STATUS.getStatusCode());
} catch (MetadataException e) {
LOGGER.error("Error StorageGroup name", e);
- result.setCode(TSStatusCode.STORAGE_GROUP_NOT_EXIST.getStatusCode());
+ result.setCode(TSStatusCode.DATABASE_NOT_EXIST.getStatusCode());
} finally {
storageGroupReadWriteLock.writeLock().unlock();
}
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/persistence/sync/ClusterSyncInfo.java b/confignode/src/main/java/org/apache/iotdb/confignode/persistence/sync/ClusterSyncInfo.java
index b2805d658b..6ff5fb0ae6 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/persistence/sync/ClusterSyncInfo.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/persistence/sync/ClusterSyncInfo.java
@@ -82,7 +82,7 @@ public class ClusterSyncInfo implements SnapshotProcessor {
status.setCode(TSStatusCode.SUCCESS_STATUS.getStatusCode());
} catch (PipeSinkException e) {
LOGGER.error("failed to execute CreatePipeSinkPlan {} on ClusterSyncInfo", plan, e);
- status.setCode(TSStatusCode.PIPESINK_ERROR.getStatusCode());
+ status.setCode(TSStatusCode.CREATE_PIPE_SINK_ERROR.getStatusCode());
LOGGER.error(e.getMessage());
}
return status;
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/ConfigNodeRPCServiceProcessor.java b/confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/ConfigNodeRPCServiceProcessor.java
index 7c2fc48269..4a81e3b38a 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/ConfigNodeRPCServiceProcessor.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/ConfigNodeRPCServiceProcessor.java
@@ -576,7 +576,7 @@ public class ConfigNodeRPCServiceProcessor implements IConfigNodeRPCService.Ifac
StringBuilder sb = new StringBuilder();
noExistSg.forEach(storageGroup -> sb.append(storageGroup.getFullPath()).append(","));
return RpcUtils.getStatus(
- TSStatusCode.STORAGE_GROUP_NOT_EXIST,
+ TSStatusCode.DATABASE_NOT_EXIST,
"storageGroup " + sb.subSequence(0, sb.length() - 1) + " does not exist");
}
}
diff --git a/docs/UserGuide/API/Status-Codes.md b/docs/UserGuide/API/Status-Codes.md
index a00c409022..58f19d029b 100644
--- a/docs/UserGuide/API/Status-Codes.md
+++ b/docs/UserGuide/API/Status-Codes.md
@@ -21,7 +21,7 @@
# Status Codes
-**Status Code** is introduced in the latest version. A sample solution as IoTDB requires registering the time series first before writing data is:
+A sample solution as IoTDB requires registering the time series first before writing data is:
```
try {
@@ -51,22 +51,39 @@ Here is a list of Status Code and related message:
|298|NODE_DELETE_FAILED_ERROR|Failed while deleting node|
|299|ALIAS_ALREADY_EXIST_ERROR|Alias already exists|
|300|PATH_ALREADY_EXIST_ERROR|Path already exists|
-|301|PATH_NOT_EXIST_ERROR|Path does not exist|
|302|UNSUPPORTED_FETCH_METADATA_OPERATION_ERROR|Unsupported fetch metadata operation|
|303|METADATA_ERROR|Meet error when dealing with metadata|
+|304|PATH_NOT_EXIST_ERROR|Path does not exist|
|305|OUT_OF_TTL_ERROR|Insertion time is less than TTL time bound|
-|306|CONFIG_ADJUSTER|IoTDB system load is too large|
+|306|HEAVY_WORKLOAD|IoTDB system load is too large|
|307|MERGE_ERROR|Meet error while merging|
|308|SYSTEM_CHECK_ERROR|Meet error while system checking|
-|309|SYNC_DEVICE_OWNER_CONFLICT_ERROR|Sync device owners conflict|
|310|SYNC_CONNECTION_EXCEPTION|Meet error while sync connecting|
-|311|STORAGE_GROUP_PROCESSOR_ERROR|Database processor related error|
-|312|STORAGE_GROUP_ERROR|Database related error|
+|311|DATABASE_PROCESS_ERROR|Database processor related error|
|313|STORAGE_ENGINE_ERROR|Storage engine related error|
|314|TSFILE_PROCESSOR_ERROR|TsFile processor related error|
|315|PATH_ILLEGAL|Illegal path|
|316|LOAD_FILE_ERROR|Meet error while loading file|
-|317|STORAGE_GROUP_NOT_READY| The database is in recovery mode, not ready fore accepting read/write operation|
+|317|DATABASE_NOT_READY| The database is in recovery mode, not ready fore accepting read/write operation|
+|318|ILLEGAL_PARAMETER| Parameter is illegal |
+|319|ALIGNED_TIMESERIES_ERROR| Meet error in aligned timeseries |
+|320|DUPLICATED_TEMPLATE| Schema template is duplicated |
+|321|UNDEFINED_TEMPLATE| Schema template is not defined |
+|322|DATABASE_NOT_EXIST| Database does not exist |
+|323|CONTINUOUS_QUERY_ERROR| Continuous query error |
+|324|NO_TEMPLATE_ON_MNODE| No schema template on current MNode |
+|325|DIFFERENT_TEMPLATE| Template is not consistent |
+|326|TEMPLATE_IS_IN_USE| Template is in use |
+|327|TEMPLATE_INCOMPATIBLE| Template is not compatible |
+|328|SEGMENT_NOT_FOUND| Segment not found |
+|329|PAGE_OUT_OF_SPACE| No enough space on schema page |
+|330|RECORD_DUPLICATED| Record is duplicated |
+|331|SEGMENT_OUT_OF_SPACE| No enough space on schema segment |
+|332|SCHEMA_FILE_NOT_EXISTS| SchemaFile does not exist |
+|333|WRITE_AHEAD_LOG_ERROR| WAL error |
+|334|CREATE_PIPE_SINK_ERROR| Error in creating PIPE sink |
+|335|PIPE_ERROR| PIPE error |
+|336|PIPESERVER_ERROR| PIPE server error |
|400|EXECUTE_STATEMENT_ERROR|Execute statement error|
|401|SQL_PARSE_ERROR|Meet error while parsing SQL|
|402|GENERATE_TIME_ZONE_ERROR|Meet error while generating time zone|
diff --git a/docs/zh/UserGuide/API/Status-Codes.md b/docs/zh/UserGuide/API/Status-Codes.md
index 438adf7a95..d055908e68 100644
--- a/docs/zh/UserGuide/API/Status-Codes.md
+++ b/docs/zh/UserGuide/API/Status-Codes.md
@@ -21,7 +21,7 @@
# 状态码
-从 0.10 版本开始 IoTDB 引入了**状态码**这一概念。例如，因为 IoTDB 需要在写入数据之前首先注册时间序列，一种可能的解决方案是：
+IoTDB 引入了**状态码**这一概念。例如，因为 IoTDB 需要在写入数据之前首先注册时间序列，一种可能的解决方案是：
```
try {
@@ -38,7 +38,8 @@ try {
```
-利用状态码，我们就可以不必写诸如`if (e.getErrorMessage().contains("exist"))`的代码，只需要使用`e.getStatusType().getCode() == TSStatusCode.TIME_SERIES_NOT_EXIST_ERROR.getStatusCode()`。
+利用状态码，我们就可以不必写诸如`if (e.getErrorMessage().contains("exist"))`的代码，
+只需要使用`e.getStatusType().getCode() == TSStatusCode.TIME_SERIES_NOT_EXIST_ERROR.getStatusCode()`。
这里是状态码和相对应信息的列表：
@@ -51,22 +52,39 @@ try {
|298|NODE_DELETE_FAILED_ERROR|删除节点失败|
|299|ALIAS_ALREADY_EXIST_ERROR|路径别名已经存在|
|300|PATH_ALREADY_EXIST_ERROR|路径已经存在|
-|301|PATH_NOT_EXIST_ERROR|路径不存在|
|302|UNSUPPORTED_FETCH_METADATA_OPERATION_ERROR|不支持的获取元数据操作|
|303|METADATA_ERROR|处理元数据错误|
+|304|PATH_NOT_EXIST_ERROR|路径不存在|
|305|OUT_OF_TTL_ERROR|插入时间少于 TTL 时间边界|
-|306|CONFIG_ADJUSTER|IoTDB 系统负载过大|
+|306|HEAVY_WORKLOAD|IoTDB 系统负载过大|
|307|MERGE_ERROR|合并错误|
|308|SYSTEM_CHECK_ERROR|系统检查错误|
-|309|SYNC_DEVICE_OWNER_CONFLICT_ERROR|回传设备冲突错误|
|310|SYNC_CONNECTION_EXCEPTION|回传连接错误|
-|311|STORAGE_GROUP_PROCESSOR_ERROR|存储组处理器相关错误|
-|312|STORAGE_GROUP_ERROR|存储组相关错误|
+|311|DATABASE_PROCESS_ERROR|存储组处理器相关错误|
|313|STORAGE_ENGINE_ERROR|存储引擎相关错误|
|314|TSFILE_PROCESSOR_ERROR|TsFile 处理器相关错误|
|315|PATH_ILLEGAL|路径不合法|
|316|LOAD_FILE_ERROR|加载文件错误|
-|317|STORAGE_GROUP_NOT_READY| 存储组还在恢复中，还不能接受读写操作 |
+|317|DATABASE_NOT_READY| Database 还在恢复中，还不能接受读写操作 |
+|318|ILLEGAL_PARAMETER| 参数错误 |
+|319|ALIGNED_TIMESERIES_ERROR| 对齐时间序列错误 |
+|320|DUPLICATED_TEMPLATE| 元数据模板重复 |
+|321|UNDEFINED_TEMPLATE| 元数据模板未定义 |
+|322|DATABASE_NOT_EXIST| 数据库不存在 |
+|323|CONTINUOUS_QUERY_ERROR| 连续查询功能错误 |
+|324|NO_TEMPLATE_ON_MNODE| 当前元数据节点不存在元数据模板 |
+|325|DIFFERENT_TEMPLATE| 元数据模板不一致 |
+|326|TEMPLATE_IS_IN_USE| 元数据模板正在使用 |
+|327|TEMPLATE_INCOMPATIBLE| 元数据模板不兼容 |
+|328|SEGMENT_NOT_FOUND| 未找到 Segment |
+|329|PAGE_OUT_OF_SPACE| SchemaFile 中 Page 空间不够 |
+|330|RECORD_DUPLICATED| 记录重复 |
+|331|SEGMENT_OUT_OF_SPACE| SchemaFile 中 segment 空间不够 |
+|332|SCHEMA_FILE_NOT_EXISTS| SchemaFile 不存在 |
+|333|WRITE_AHEAD_LOG_ERROR| WAL 异常 |
+|334|CREATE_PIPE_SINK_ERROR| 创建 PIPE Sink 异常 |
+|335|PIPE_ERROR| PIPE 异常 |
+|336|PIPESERVER_ERROR| PIPE server 异常 |
|400|EXECUTE_STATEMENT_ERROR|执行语句错误|
|401|SQL_PARSE_ERROR|SQL 语句分析错误|
|402|GENERATE_TIME_ZONE_ERROR|生成时区错误|
diff --git a/integration/src/test/java/org/apache/iotdb/db/integration/IoTDBTtlIT.java b/integration/src/test/java/org/apache/iotdb/db/integration/IoTDBTtlIT.java
index 855c119fab..bb354186fe 100644
--- a/integration/src/test/java/org/apache/iotdb/db/integration/IoTDBTtlIT.java
+++ b/integration/src/test/java/org/apache/iotdb/db/integration/IoTDBTtlIT.java
@@ -61,12 +61,12 @@ public class IoTDBTtlIT {
try {
statement.execute("SET TTL TO root.TTL_SG1 1000");
} catch (SQLException e) {
- assertEquals(TSStatusCode.TIMESERIES_NOT_EXIST.getStatusCode(), e.getErrorCode());
+ assertEquals(TSStatusCode.PATH_NOT_EXIST_ERROR.getStatusCode(), e.getErrorCode());
}
try {
statement.execute("UNSET TTL TO root.TTL_SG1");
} catch (SQLException e) {
- assertEquals(TSStatusCode.TIMESERIES_NOT_EXIST.getStatusCode(), e.getErrorCode());
+ assertEquals(TSStatusCode.PATH_NOT_EXIST_ERROR.getStatusCode(), e.getErrorCode());
}
statement.execute("CREATE DATABASE root.TTL_SG1");
@@ -74,7 +74,7 @@ public class IoTDBTtlIT {
try {
statement.execute("SET TTL TO root.TTL_SG1.s1 1000");
} catch (SQLException e) {
- assertEquals(TSStatusCode.STORAGE_GROUP_NOT_EXIST.getStatusCode(), e.getErrorCode());
+ assertEquals(TSStatusCode.DATABASE_NOT_EXIST.getStatusCode(), e.getErrorCode());
}
statement.execute("CREATE DATABASE root.TTL_SG2");
@@ -82,24 +82,24 @@ public class IoTDBTtlIT {
try {
statement.execute("SET TTL TO root.TTL_SG2.s1 1000");
} catch (SQLException e) {
- assertEquals(TSStatusCode.STORAGE_GROUP_NOT_EXIST.getStatusCode(), e.getErrorCode());
+ assertEquals(TSStatusCode.DATABASE_NOT_EXIST.getStatusCode(), e.getErrorCode());
}
try {
statement.execute("SET TTL TO root.** 1000");
} catch (SQLException e) {
- assertEquals(TSStatusCode.TIMESERIES_NOT_EXIST.getStatusCode(), e.getErrorCode());
+ assertEquals(TSStatusCode.PATH_NOT_EXIST_ERROR.getStatusCode(), e.getErrorCode());
}
try {
statement.execute("UNSET TTL TO root.**");
} catch (SQLException e) {
- assertEquals(TSStatusCode.TIMESERIES_NOT_EXIST.getStatusCode(), e.getErrorCode());
+ assertEquals(TSStatusCode.PATH_NOT_EXIST_ERROR.getStatusCode(), e.getErrorCode());
}
try {
statement.execute("SET TTL TO root.**.s1 1000");
} catch (SQLException e) {
- assertEquals(TSStatusCode.STORAGE_GROUP_NOT_EXIST.getStatusCode(), e.getErrorCode());
+ assertEquals(TSStatusCode.DATABASE_NOT_EXIST.getStatusCode(), e.getErrorCode());
}
long now = System.currentTimeMillis();
diff --git a/node-commons/src/main/java/org/apache/iotdb/commons/exception/sync/PipeSinkException.java b/node-commons/src/main/java/org/apache/iotdb/commons/exception/sync/PipeSinkException.java
index acaafb476c..f2711b0f79 100644
--- a/node-commons/src/main/java/org/apache/iotdb/commons/exception/sync/PipeSinkException.java
+++ b/node-commons/src/main/java/org/apache/iotdb/commons/exception/sync/PipeSinkException.java
@@ -31,12 +31,12 @@ public class PipeSinkException extends IoTDBException {
}
public PipeSinkException(String message) {
- super(message, TSStatusCode.PIPESINK_ERROR.getStatusCode());
+ super(message, TSStatusCode.CREATE_PIPE_SINK_ERROR.getStatusCode());
}
public PipeSinkException(String attr, String value, String attrType) {
super(
String.format("%s=%s has wrong format, require for %s.", attr, value, attrType),
- TSStatusCode.PIPESINK_ERROR.getStatusCode());
+ TSStatusCode.CREATE_PIPE_SINK_ERROR.getStatusCode());
}
}
diff --git a/node-commons/src/main/java/org/apache/iotdb/commons/utils/StatusUtils.java b/node-commons/src/main/java/org/apache/iotdb/commons/utils/StatusUtils.java
index dc2d0ae966..d2e3ed2035 100644
--- a/node-commons/src/main/java/org/apache/iotdb/commons/utils/StatusUtils.java
+++ b/node-commons/src/main/java/org/apache/iotdb/commons/utils/StatusUtils.java
@@ -29,24 +29,10 @@ import java.util.Map;
public class StatusUtils {
private StatusUtils() {}
- public static final TSStatus PARTITION_TABLE_NOT_READY =
- getStatus(TSStatusCode.PARTITION_NOT_READY);
public static final TSStatus OK = getStatus(TSStatusCode.SUCCESS_STATUS);
- public static final TSStatus TIME_OUT = getStatus(TSStatusCode.TIME_OUT);
- public static final TSStatus NO_LEADER = getStatus(TSStatusCode.NO_LEADER);
public static final TSStatus INTERNAL_ERROR = getStatus(TSStatusCode.INTERNAL_SERVER_ERROR);
- public static final TSStatus UNSUPPORTED_OPERATION =
- getStatus(TSStatusCode.UNSUPPORTED_OPERATION);
public static final TSStatus EXECUTE_STATEMENT_ERROR =
getStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR);
- public static final TSStatus NO_STORAGE_GROUP = getStatus(TSStatusCode.STORAGE_GROUP_ERROR);
- public static final TSStatus NODE_READ_ONLY = getStatus(TSStatusCode.NODE_READ_ONLY);
- public static final TSStatus CONSISTENCY_FAILURE = getStatus(TSStatusCode.CONSISTENCY_FAILURE);
- public static final TSStatus TIMESERIES_NOT_EXIST_ERROR =
- getStatus(TSStatusCode.TIMESERIES_NOT_EXIST);
- public static final TSStatus NO_CONNECTION = getStatus(TSStatusCode.NO_CONNECTION);
- public static final TSStatus PARSE_LOG_ERROR = getStatus(TSStatusCode.PARSE_LOG_ERROR);
- public static final TSStatus DUPLICATED_TEMPLATE = getStatus(TSStatusCode.DUPLICATED_TEMPLATE);
/**
* @param statusMap index -> status
@@ -69,144 +55,137 @@ public class StatusUtils {
status.setCode(statusCode.getStatusCode());
switch (statusCode) {
case SUCCESS_STATUS:
- status.setMessage("Executed successfully. ");
+ status.setMessage("Executed successfully.");
break;
case TIME_OUT:
- status.setMessage("Request timed out. ");
+ status.setMessage("Request timed out.");
break;
case NO_LEADER:
- status.setMessage("Leader cannot be found. ");
+ status.setMessage("Leader cannot be found.");
break;
case PARTITION_NOT_READY:
- status.setMessage("Partition table is not ready. ");
- break;
- case NODE_READ_ONLY:
- status.setMessage(
- "Current node is read-only, please retry to find another available node. ");
+ status.setMessage("Partition table is not ready.");
break;
case INCOMPATIBLE_VERSION:
- status.setMessage("Incompatible version. ");
+ status.setMessage("Incompatible version.");
break;
case NODE_DELETE_FAILED_ERROR:
- status.setMessage("Failed while deleting node. ");
+ status.setMessage("Failed while deleting node.");
break;
case ALIAS_ALREADY_EXIST_ERROR:
- status.setMessage("Alias already exists. ");
+ status.setMessage("Alias already exists.");
break;
case PATH_ALREADY_EXIST_ERROR:
- status.setMessage("Path already exist. ");
+ status.setMessage("Path already exist.");
break;
case PATH_NOT_EXIST_ERROR:
- case TIMESERIES_NOT_EXIST:
- status.setMessage("Path does not exist. ");
+ case PATH_NOT_EXIST_ERROR:
+ status.setMessage("Path does not exist.");
break;
case UNSUPPORTED_FETCH_METADATA_OPERATION_ERROR:
- status.setMessage("Unsupported fetch metadata operation. ");
+ status.setMessage("Unsupported fetch metadata operation.");
break;
case METADATA_ERROR:
- status.setMessage("Meet error when dealing with metadata. ");
+ status.setMessage("Meet error when dealing with metadata.");
break;
case OUT_OF_TTL_ERROR:
- status.setMessage("Insertion time is less than TTL time bound. ");
+ status.setMessage("Insertion time is less than TTL time bound.");
break;
- case CONFIG_ADJUSTER:
- status.setMessage("IoTDB system load is too large. ");
+ case HEAVY_WORKLOAD:
+ status.setMessage("IoTDB system load is too large.");
break;
case MERGE_ERROR:
- status.setMessage("Meet error while merging. ");
+ status.setMessage("Meet error while merging.");
break;
case SYSTEM_CHECK_ERROR:
- status.setMessage("Meet error while system checking. ");
+ status.setMessage("Meet error while system checking.");
break;
case SYNC_CONNECTION_EXCEPTION:
- status.setMessage("Meet error while sync connecting. ");
- break;
- case DATA_REGION_ERROR:
- status.setMessage("Database processor related error. ");
+ status.setMessage("Meet error while sync connecting.");
break;
- case STORAGE_GROUP_ERROR:
- status.setMessage("No associated database. ");
+ case DATABASE_PROCESS_ERROR:
+ status.setMessage("Database processor related error.");
break;
case STORAGE_ENGINE_ERROR:
- status.setMessage("Storage engine related error. ");
+ status.setMessage("Storage engine related error.");
break;
case TSFILE_PROCESSOR_ERROR:
- status.setMessage("TsFile processor related error. ");
+ status.setMessage("TsFile processor related error.");
break;
case PATH_ILLEGAL:
- status.setMessage("Illegal path. ");
+ status.setMessage("Illegal path.");
break;
case LOAD_FILE_ERROR:
- status.setMessage("Meet error while loading file. ");
+ status.setMessage("Meet error while loading file.");
break;
case EXECUTE_STATEMENT_ERROR:
- status.setMessage("Execute statement error. ");
+ status.setMessage("Execute statement error.");
break;
case SQL_PARSE_ERROR:
- status.setMessage("Meet error while parsing SQL. ");
+ status.setMessage("Meet error while parsing SQL.");
break;
case GENERATE_TIME_ZONE_ERROR:
- status.setMessage("Meet error while generating time zone. ");
+ status.setMessage("Meet error while generating time zone.");
break;
case SET_TIME_ZONE_ERROR:
- status.setMessage("Meet error while setting time zone. ");
+ status.setMessage("Meet error while setting time zone.");
break;
case NOT_STORAGE_GROUP_ERROR:
- status.setMessage("Operating object is not a database. ");
+ status.setMessage("Operating object is not a database.");
break;
case QUERY_NOT_ALLOWED:
- status.setMessage("Query statements are not allowed error. ");
+ status.setMessage("Query statements are not allowed error.");
break;
case AST_FORMAT_ERROR:
- status.setMessage("AST format related error. ");
+ status.setMessage("AST format related error.");
break;
case LOGICAL_OPERATOR_ERROR:
- status.setMessage("Logical operator related error. ");
+ status.setMessage("Logical operator related error.");
break;
case LOGICAL_OPTIMIZE_ERROR:
- status.setMessage("Logical optimize related error. ");
+ status.setMessage("Logical optimize related error.");
break;
case UNSUPPORTED_FILL_TYPE_ERROR:
- status.setMessage("Unsupported fill type related error. ");
+ status.setMessage("Unsupported fill type related error.");
break;
case PATH_ERROR:
- status.setMessage("Path related error. ");
+ status.setMessage("Path related error.");
break;
case QUERY_PROCESS_ERROR:
- status.setMessage("Query process related error. ");
+ status.setMessage("Query process related error.");
break;
case WRITE_PROCESS_ERROR:
- status.setMessage("Writing data related error. ");
+ status.setMessage("Writing data related error.");
break;
case INTERNAL_SERVER_ERROR:
- status.setMessage("Internal server error. ");
+ status.setMessage("Internal server error.");
break;
case CLOSE_OPERATION_ERROR:
- status.setMessage("Meet error in close operation. ");
+ status.setMessage("Meet error in close operation.");
break;
case READ_ONLY_SYSTEM_ERROR:
- status.setMessage("Database is read-only. ");
+ status.setMessage("Database is read-only.");
break;
case DISK_SPACE_INSUFFICIENT_ERROR:
- status.setMessage("Disk space is insufficient. ");
+ status.setMessage("Disk space is insufficient.");
break;
case START_UP_ERROR:
- status.setMessage("Meet error while starting up. ");
+ status.setMessage("Meet error while starting up.");
break;
case WRONG_LOGIN_PASSWORD_ERROR:
- status.setMessage("Username or password is wrong. ");
+ status.setMessage("Username or password is wrong.");
break;
case NOT_LOGIN_ERROR:
- status.setMessage("Has not logged in. ");
+ status.setMessage("Has not logged in.");
break;
case NO_PERMISSION_ERROR:
- status.setMessage("No permissions for this operation, please add privilege. ");
+ status.setMessage("No permissions for this operation, please add privilege.");
break;
case UNINITIALIZED_AUTH_ERROR:
- status.setMessage("Uninitialized authorizer. ");
+ status.setMessage("Uninitialized authorizer.");
break;
case UNSUPPORTED_OPERATION:
- status.setMessage("Unsupported operation. ");
+ status.setMessage("Unsupported operation.");
break;
case NO_CONNECTION:
status.setMessage("Node cannot be reached.");
diff --git a/server/src/main/java/org/apache/iotdb/db/engine/StorageEngineV2.java b/server/src/main/java/org/apache/iotdb/db/engine/StorageEngineV2.java
index 4c03ee5a67..30c6f2500b 100644
--- a/server/src/main/java/org/apache/iotdb/db/engine/StorageEngineV2.java
+++ b/server/src/main/java/org/apache/iotdb/db/engine/StorageEngineV2.java
@@ -724,7 +724,7 @@ public class StorageEngineV2 implements IService {
"IO error when writing piece node of TsFile %s to DataRegion %s.",
pieceNode.getTsFile(), dataRegionId),
e);
- status.setCode(TSStatusCode.DATA_REGION_ERROR.getStatusCode());
+ status.setCode(TSStatusCode.DATABASE_PROCESS_ERROR.getStatusCode());
status.setMessage(e.getMessage());
return status;
}
@@ -765,7 +765,7 @@ public class StorageEngineV2 implements IService {
}
} catch (IOException e) {
logger.error(String.format("Execute load command %s error.", loadCommand), e);
- status.setCode(TSStatusCode.DATA_REGION_ERROR.getStatusCode());
+ status.setCode(TSStatusCode.DATABASE_PROCESS_ERROR.getStatusCode());
status.setMessage(e.getMessage());
} catch (LoadFileException e) {
logger.error(String.format("Execute load command %s error.", loadCommand), e);
diff --git a/server/src/main/java/org/apache/iotdb/db/exception/DataRegionException.java b/server/src/main/java/org/apache/iotdb/db/exception/DataRegionException.java
index 329a9cb249..5c76935147 100644
--- a/server/src/main/java/org/apache/iotdb/db/exception/DataRegionException.java
+++ b/server/src/main/java/org/apache/iotdb/db/exception/DataRegionException.java
@@ -26,10 +26,10 @@ public class DataRegionException extends IoTDBException {
private static final long serialVersionUID = 7373978140952977661L;
public DataRegionException(Exception exception) {
- super(exception, TSStatusCode.DATA_REGION_ERROR.getStatusCode());
+ super(exception, TSStatusCode.DATABASE_PROCESS_ERROR.getStatusCode());
}
public DataRegionException(String message) {
- super(message, TSStatusCode.DATA_REGION_ERROR.getStatusCode());
+ super(message, TSStatusCode.DATABASE_PROCESS_ERROR.getStatusCode());
}
}
diff --git a/server/src/main/java/org/apache/iotdb/db/exception/metadata/PathNotExistException.java b/server/src/main/java/org/apache/iotdb/db/exception/metadata/PathNotExistException.java
index b7b5950f14..60b7775a1f 100644
--- a/server/src/main/java/org/apache/iotdb/db/exception/metadata/PathNotExistException.java
+++ b/server/src/main/java/org/apache/iotdb/db/exception/metadata/PathNotExistException.java
@@ -31,13 +31,13 @@ public class PathNotExistException extends MetadataException {
public PathNotExistException(String path) {
super(
String.format(PATH_NOT_EXIST_WRONG_MESSAGE, path),
- TSStatusCode.TIMESERIES_NOT_EXIST.getStatusCode());
+ TSStatusCode.PATH_NOT_EXIST_ERROR.getStatusCode());
}
public PathNotExistException(String path, boolean isUserException) {
super(
String.format(PATH_NOT_EXIST_WRONG_MESSAGE, path),
- TSStatusCode.TIMESERIES_NOT_EXIST.getStatusCode(),
+ TSStatusCode.PATH_NOT_EXIST_ERROR.getStatusCode(),
isUserException);
}
@@ -48,6 +48,6 @@ public class PathNotExistException extends MetadataException {
paths.size() == 1
? paths.get(0)
: paths.get(0) + " ... " + paths.get(paths.size() - 1)),
- TSStatusCode.TIMESERIES_NOT_EXIST.getStatusCode());
+ TSStatusCode.PATH_NOT_EXIST_ERROR.getStatusCode());
}
}
diff --git a/server/src/main/java/org/apache/iotdb/db/exception/metadata/StorageGroupNotSetException.java b/server/src/main/java/org/apache/iotdb/db/exception/metadata/StorageGroupNotSetException.java
index 4a0428fd87..3f48ab9f14 100644
--- a/server/src/main/java/org/apache/iotdb/db/exception/metadata/StorageGroupNotSetException.java
+++ b/server/src/main/java/org/apache/iotdb/db/exception/metadata/StorageGroupNotSetException.java
@@ -28,13 +28,13 @@ public class StorageGroupNotSetException extends MetadataException {
public StorageGroupNotSetException(String path) {
super(String.format("Database is not set for current seriesPath: [%s]", path));
- this.errorCode = TSStatusCode.STORAGE_GROUP_NOT_EXIST.getStatusCode();
+ this.errorCode = TSStatusCode.DATABASE_NOT_EXIST.getStatusCode();
}
public StorageGroupNotSetException(String path, boolean isUserException) {
super(String.format("Database is not set for current seriesPath: [%s]", path));
this.isUserException = isUserException;
- this.errorCode = TSStatusCode.STORAGE_GROUP_NOT_EXIST.getStatusCode();
+ this.errorCode = TSStatusCode.DATABASE_NOT_EXIST.getStatusCode();
}
public StorageGroupNotSetException(String path, String reason) {
diff --git a/server/src/main/java/org/apache/iotdb/db/exception/metadata/template/TemplateImcompatibeException.java b/server/src/main/java/org/apache/iotdb/db/exception/metadata/template/TemplateImcompatibeException.java
index 9dc21a8c2c..9e3a8fb1fd 100644
--- a/server/src/main/java/org/apache/iotdb/db/exception/metadata/template/TemplateImcompatibeException.java
+++ b/server/src/main/java/org/apache/iotdb/db/exception/metadata/template/TemplateImcompatibeException.java
@@ -28,14 +28,14 @@ public class TemplateImcompatibeException extends MetadataException {
public TemplateImcompatibeException(String path, String templateName) {
super(
String.format("Path [%s] already exists in [%s]", path, templateName),
- TSStatusCode.TEMPLATE_IMCOMPATIBLE.getStatusCode());
+ TSStatusCode.TEMPLATE_INCOMPATIBLE.getStatusCode());
this.isUserException = true;
}
public TemplateImcompatibeException(String path, String templateName, String overlapNodeName) {
super(
String.format("Path [%s] overlaps with [%s] on [%s]", path, templateName, overlapNodeName),
- TSStatusCode.TEMPLATE_IMCOMPATIBLE.getStatusCode());
+ TSStatusCode.TEMPLATE_INCOMPATIBLE.getStatusCode());
this.isUserException = true;
}
}
diff --git a/server/src/main/java/org/apache/iotdb/db/localconfignode/LocalConfigNode.java b/server/src/main/java/org/apache/iotdb/db/localconfignode/LocalConfigNode.java
index ab593bf819..3416de7a30 100644
--- a/server/src/main/java/org/apache/iotdb/db/localconfignode/LocalConfigNode.java
+++ b/server/src/main/java/org/apache/iotdb/db/localconfignode/LocalConfigNode.java
@@ -1322,7 +1322,7 @@ public class LocalConfigNode {
try {
syncService.addPipeSink(createPipeSinkStatement);
} catch (PipeSinkException e) {
- return RpcUtils.getStatus(TSStatusCode.PIPESINK_ERROR, e.getMessage());
+ return RpcUtils.getStatus(TSStatusCode.CREATE_PIPE_SINK_ERROR, e.getMessage());
}
return RpcUtils.getStatus(TSStatusCode.SUCCESS_STATUS);
}
@@ -1331,7 +1331,7 @@ public class LocalConfigNode {
try {
syncService.dropPipeSink(pipeSinkName);
} catch (PipeSinkException e) {
- return RpcUtils.getStatus(TSStatusCode.PIPESINK_ERROR, e.getMessage());
+ return RpcUtils.getStatus(TSStatusCode.CREATE_PIPE_SINK_ERROR, e.getMessage());
}
return RpcUtils.getStatus(TSStatusCode.SUCCESS_STATUS);
}
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/executor/StandaloneConfigTaskExecutor.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/executor/StandaloneConfigTaskExecutor.java
index 62ae2e5b2b..4d8b5ee001 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/executor/StandaloneConfigTaskExecutor.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/executor/StandaloneConfigTaskExecutor.java
@@ -192,7 +192,7 @@ public class StandaloneConfigTaskExecutor implements IConfigTaskExecutor {
String.format(
"Path %s does not exist",
Arrays.toString(deleteStorageGroupStatement.getPrefixPath().toArray())),
- TSStatusCode.TIMESERIES_NOT_EXIST.getStatusCode()));
+ TSStatusCode.PATH_NOT_EXIST_ERROR.getStatusCode()));
return future;
} else {
LocalConfigNode.getInstance().deleteStorageGroups(deletePathList);
diff --git a/server/src/main/java/org/apache/iotdb/db/sync/common/LocalSyncInfoFetcher.java b/server/src/main/java/org/apache/iotdb/db/sync/common/LocalSyncInfoFetcher.java
index 923828ceda..956f4698a4 100644
--- a/server/src/main/java/org/apache/iotdb/db/sync/common/LocalSyncInfoFetcher.java
+++ b/server/src/main/java/org/apache/iotdb/db/sync/common/LocalSyncInfoFetcher.java
@@ -91,7 +91,7 @@ public class LocalSyncInfoFetcher implements ISyncInfoFetcher {
} catch (IOException e) {
return RpcUtils.getStatus(TSStatusCode.INTERNAL_SERVER_ERROR, e.getMessage());
} catch (PipeSinkException e) {
- return RpcUtils.getStatus(TSStatusCode.PIPESINK_ERROR, e.getMessage());
+ return RpcUtils.getStatus(TSStatusCode.CREATE_PIPE_SINK_ERROR, e.getMessage());
}
}
diff --git a/server/src/main/java/org/apache/iotdb/db/utils/ErrorHandlingUtils.java b/server/src/main/java/org/apache/iotdb/db/utils/ErrorHandlingUtils.java
index f2aaf0a841..e01a94ab79 100644
--- a/server/src/main/java/org/apache/iotdb/db/utils/ErrorHandlingUtils.java
+++ b/server/src/main/java/org/apache/iotdb/db/utils/ErrorHandlingUtils.java
@@ -80,7 +80,7 @@ public class ErrorHandlingUtils {
TSStatus status = tryCatchQueryException(e);
if (status != null) {
// ignore logging sg not ready exception
- if (status.getCode() != TSStatusCode.STORAGE_GROUP_NOT_READY.getStatusCode()) {
+ if (status.getCode() != TSStatusCode.DATABASE_NOT_READY.getStatusCode()) {
String message =
String.format(
"Status code: %s, Query Statement: %s failed", status.getCode(), operation);
@@ -108,7 +108,7 @@ public class ErrorHandlingUtils {
Throwable rootCause = getRootCause(e);
// ignore logging sg not ready exception
if (rootCause instanceof StorageGroupNotReadyException) {
- return RpcUtils.getStatus(TSStatusCode.STORAGE_GROUP_NOT_READY, rootCause.getMessage());
+ return RpcUtils.getStatus(TSStatusCode.DATABASE_NOT_READY, rootCause.getMessage());
}
Throwable t = e instanceof ExecutionException ? e.getCause() : e;
@@ -159,7 +159,7 @@ public class ErrorHandlingUtils {
BatchProcessException batchException = (BatchProcessException) e;
// ignore logging sg not ready exception
for (TSStatus status : batchException.getFailingStatus()) {
- if (status.getCode() == TSStatusCode.STORAGE_GROUP_NOT_READY.getStatusCode()) {
+ if (status.getCode() == TSStatusCode.DATABASE_NOT_READY.getStatusCode()) {
return RpcUtils.getStatus(Arrays.asList(batchException.getFailingStatus()));
}
}
diff --git a/service-rpc/src/main/java/org/apache/iotdb/rpc/TSStatusCode.java b/service-rpc/src/main/java/org/apache/iotdb/rpc/TSStatusCode.java
index a76e4c2922..2abc593f8d 100644
--- a/service-rpc/src/main/java/org/apache/iotdb/rpc/TSStatusCode.java
+++ b/service-rpc/src/main/java/org/apache/iotdb/rpc/TSStatusCode.java
@@ -31,39 +31,37 @@ public enum TSStatusCode {
NODE_DELETE_FAILED_ERROR(298),
ALIAS_ALREADY_EXIST_ERROR(299),
PATH_ALREADY_EXIST_ERROR(300),
- PATH_NOT_EXIST_ERROR(301),
UNSUPPORTED_FETCH_METADATA_OPERATION_ERROR(302),
METADATA_ERROR(303),
- TIMESERIES_NOT_EXIST(304),
+ PATH_NOT_EXIST_ERROR(304),
OUT_OF_TTL_ERROR(305),
- CONFIG_ADJUSTER(306),
+ HEAVY_WORKLOAD(306),
MERGE_ERROR(307),
SYSTEM_CHECK_ERROR(308),
SYNC_CONNECTION_EXCEPTION(310),
- DATA_REGION_ERROR(311),
- STORAGE_GROUP_ERROR(312),
+ DATABASE_PROCESS_ERROR(311),
STORAGE_ENGINE_ERROR(313),
TSFILE_PROCESSOR_ERROR(314),
PATH_ILLEGAL(315),
LOAD_FILE_ERROR(316),
- STORAGE_GROUP_NOT_READY(317),
+ DATABASE_NOT_READY(317),
ILLEGAL_PARAMETER(318),
ALIGNED_TIMESERIES_ERROR(319),
DUPLICATED_TEMPLATE(320),
UNDEFINED_TEMPLATE(321),
- STORAGE_GROUP_NOT_EXIST(322),
+ DATABASE_NOT_EXIST(322),
CONTINUOUS_QUERY_ERROR(323),
NO_TEMPLATE_ON_MNODE(324),
DIFFERENT_TEMPLATE(325),
TEMPLATE_IS_IN_USE(326),
- TEMPLATE_IMCOMPATIBLE(327),
+ TEMPLATE_INCOMPATIBLE(327),
SEGMENT_NOT_FOUND(328),
PAGE_OUT_OF_SPACE(329),
RECORD_DUPLICATED(330),
SEGMENT_OUT_OF_SPACE(331),
SCHEMA_FILE_NOT_EXISTS(332),
WRITE_AHEAD_LOG_ERROR(333),
- PIPESINK_ERROR(334),
+ CREATE_PIPE_SINK_ERROR(334),
PIPE_ERROR(335),
PIPESERVER_ERROR(336),
SERIES_OVERFLOW(337),
@@ -138,8 +136,6 @@ public enum TSStatusCode {
TIME_OUT(701),
NO_LEADER(702),
UNSUPPORTED_OPERATION(703),
- NODE_READ_ONLY(704),
- CONSISTENCY_FAILURE(705),
NO_CONNECTION(706),
NEED_REDIRECTION(707),
PARSE_LOG_ERROR(708),