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:36 UTC
[iotdb] branch fix_statuscode created (now 0182cc2759)
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a change to branch fix_statuscode
in repository https://gitbox.apache.org/repos/asf/iotdb.git
at 0182cc2759 update status code 80%
This branch includes the following new commits:
new d22136a564 fix some status code
new 0182cc2759 update status code 80%
The 2 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] 02/02: update status code 80%
Posted by qi...@apache.org.
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 0182cc275916dbc9d2a0ed0585427d3cfd502f98
Author: qiaojialin <64...@qq.com>
AuthorDate: Mon Nov 14 23:42:20 2022 +0800
update status code 80%
---
.../confignode/manager/ClusterSchemaManager.java | 2 +-
.../iotdb/confignode/manager/SyncManager.java | 6 ++-
.../iotdb/confignode/persistence/AuthorInfo.java | 5 +--
docs/UserGuide/API/Status-Codes.md | 43 +++++++++++++++++++-
docs/zh/UserGuide/API/Status-Codes.md | 46 +++++++++++++++++++++-
.../iotdb/confignode/it/IoTDBStorageGroupIT.java | 3 +-
.../apache/iotdb/commons/utils/StatusUtils.java | 4 --
.../apache/iotdb/db/engine/StorageEngineV2.java | 2 +-
.../metadata/MeasurementAlreadyExistException.java | 2 +-
.../metadata/MeasurementInBlackListException.java | 2 +-
.../metadata/StorageGroupAlreadySetException.java | 4 +-
.../schemafile/ColossalRecordException.java | 6 +--
.../SchemaFileLogCorruptedException.java | 2 +-
.../execution/executor/RegionWriteExecutor.java | 6 +--
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 2 +-
.../db/mpp/plan/analyze/ClusterSchemaFetcher.java | 2 +-
.../config/executor/ClusterConfigTaskExecutor.java | 2 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 2 +-
.../influxdb/meta/NewInfluxDBMetaManager.java | 2 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 7 ++--
.../thrift/impl/NewInfluxDBServiceImpl.java | 2 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 26 ++++++------
22 files changed, 127 insertions(+), 51 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 dffe4df3ec..a4a0f0e6d6 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
@@ -125,7 +125,7 @@ public class ClusterSchemaManager {
if (metadataException instanceof IllegalPathException) {
result = new TSStatus(TSStatusCode.PATH_ILLEGAL.getStatusCode());
} else {
- result = new TSStatus(TSStatusCode.STORAGE_GROUP_ALREADY_EXISTS.getStatusCode());
+ result = new TSStatus(TSStatusCode.DATABASE_ALREADY_EXISTS.getStatusCode());
}
result.setMessage(metadataException.getMessage());
return result;
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 e57e1ef089..288326f936 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,8 @@ public class SyncManager {
return getConsensusManager().write(plan).getStatus();
} catch (PipeSinkException e) {
LOGGER.error(e.getMessage());
- return new TSStatus(TSStatusCode.CREATE_PIPE_SINK_ERROR.getStatusCode()).setMessage(e.getMessage());
+ return new TSStatus(TSStatusCode.CREATE_PIPE_SINK_ERROR.getStatusCode())
+ .setMessage(e.getMessage());
}
}
@@ -105,7 +106,8 @@ public class SyncManager {
return getConsensusManager().write(plan).getStatus();
} catch (PipeSinkException e) {
LOGGER.error(e.getMessage());
- return new TSStatus(TSStatusCode.CREATE_PIPE_SINK_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/persistence/AuthorInfo.java b/confignode/src/main/java/org/apache/iotdb/confignode/persistence/AuthorInfo.java
index 69a225f293..2ced5707cb 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/persistence/AuthorInfo.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/persistence/AuthorInfo.java
@@ -118,8 +118,7 @@ public class AuthorInfo implements SnapshotProcessor {
result = getUserPermissionInfo(username);
result.setStatus(RpcUtils.getStatus(TSStatusCode.SUCCESS_STATUS));
} catch (AuthException e) {
- result.setStatus(
- RpcUtils.getStatus(TSStatusCode.EXECUTE_PERMISSION_EXCEPTION_ERROR, e.getMessage()));
+ result.setStatus(RpcUtils.getStatus(TSStatusCode.EXECUTE_PERMISSION_ERROR, e.getMessage()));
}
} else {
result = AuthUtils.generateEmptyPermissionInfoResp();
@@ -203,7 +202,7 @@ public class AuthorInfo implements SnapshotProcessor {
throw new AuthException("unknown type: " + authorPlan.getAuthorType());
}
} catch (AuthException e) {
- return RpcUtils.getStatus(TSStatusCode.EXECUTE_PERMISSION_EXCEPTION_ERROR, e.getMessage());
+ return RpcUtils.getStatus(TSStatusCode.EXECUTE_PERMISSION_ERROR, e.getMessage());
}
return RpcUtils.getStatus(TSStatusCode.SUCCESS_STATUS);
}
diff --git a/docs/UserGuide/API/Status-Codes.md b/docs/UserGuide/API/Status-Codes.md
index 58f19d029b..e354faa9d6 100644
--- a/docs/UserGuide/API/Status-Codes.md
+++ b/docs/UserGuide/API/Status-Codes.md
@@ -84,6 +84,26 @@ Here is a list of Status Code and related message:
|334|CREATE_PIPE_SINK_ERROR| Error in creating PIPE sink |
|335|PIPE_ERROR| PIPE error |
|336|PIPESERVER_ERROR| PIPE server error |
+|337|SERIES_OVERFLOW| Series number exceeds the threshold |
+|339|TEMPLATE_NOT_EXIST| Schema template does not exist |
+|340|CREATE_TEMPLATE_ERROR| Create schema template error |
+|341|SYNC_FILE_REBASE| Sync TsFile error |
+|342|SYNC_FILE_ERROR| Sync TsFile error |
+|343|VERIFY_METADATA_ERROR| Meet error in validate timeseries schema |
+|344|TIMESERIES_IN_BLACK_LIST| Timeseries is being deleted |
+|349|OVERSIZE_RECORD| Size of record exceeds the threshold of page of SchemaFile |
+|350|SCHEMA_FILE_REDO_LOG_BROKEN| SchemaFile redo log has broken |
+|355|TRIGGER_FIRE_ERROR| Error when firing trigger |
+|360|TRIGGER_LOAD_CLASS_ERROR| Error when load class of trigger |
+|361|TRIGGER_DOWNLOAD_ERROR| Error when download trigger from ConfigNode |
+|362|CREATE_TRIGGER_INSTANCE_ERROR| Error when create trigger instance |
+|363|ACTIVE_TRIGGER_INSTANCE_ERROR| Error when activate trigger instance |
+|364|DROP_TRIGGER_INSTANCE_ERROR| Error when drop trigger instance |
+|365|UPDATE_TRIGGER_LOCATION_ERROR| Error when move stateful trigger to new datanode |
+|370|UDF_LOAD_CLASS_ERROR| Error when loading UDF class |
+|371|UDF_DOWNLOAD_ERROR| Error when download UDF class from ConfigNode |
+|372|CREATE_FUNCTION_ON_DATANODE_ERROR| Error when create UDF on DataNode |
+|373|DROP_FUNCTION_ON_DATANODE_ERROR| Error when drop a UDF on DataNode |
|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|
@@ -99,6 +119,10 @@ Here is a list of Status Code and related message:
|412|WRITE_PROCESS_ERROR|Writing data related error|
|413|WRITE_PROCESS_REJECT|Writing data rejected error|
|414|QUERY_ID_NOT_EXIST|Kill query with non existent queryId|
+|415|SNAPSHOT_DIR_NOT_LEGAL|Snapshot dir name is illegal |
+|416|SEMANTIC_ERROR|SQL semantic error|
+|417|LOAD_PIECE_OF_TSFILE_ERROR|Error when load a piece of TsFile when loading|
+|423|MEMORY_NOT_ENOUGH|Not enough memory for task execution in MPP|
|500|INTERNAL_SERVER_ERROR|Internal server error|
|501|CLOSE_OPERATION_ERROR|Meet error in close operation|
|502|READ_ONLY_SYSTEM_ERROR|Operating system is read only|
@@ -107,19 +131,34 @@ Here is a list of Status Code and related message:
|505|SHUT_DOWN_ERROR|Meet error while shutdown|
|506|MULTIPLE_ERROR|Meet error when executing multiple statements|
|507|SESSION_EXPIRED|Session expired|
+|508|TSBLOCK_SERIALIZE_ERROR|TsBlock serialization error|
|600|WRONG_LOGIN_PASSWORD_ERROR|Username or password is wrong|
|601|NOT_LOGIN_ERROR|Has not logged in|
|602|NO_PERMISSION_ERROR|No permissions for this operation, please add privilege|
|603|UNINITIALIZED_AUTH_ERROR|Uninitialized authorizer|
+|605|USER_NOT_EXIST_ERROR|User does not exist|
+|606|ROLE_NOT_EXIST_ERROR|Role does not exist|
+|607|AUTHENTICATION_ERROR|Error in authentication|
+|608|CLEAR_PERMISSION_CACHE_ERROR|Error when clear the permission cache|
|700|PARTITION_NOT_READY|Partition table not ready|
|701|TIME_OUT|Operation timeout|
|702|NO_LEADER|No leader|
|703|UNSUPPORTED_OPERATION|Unsupported operation|
-|704|NODE_READ_ONLY|Node read only|
-|705|CONSISTENCY_FAILURE|Consistency check failure|
|706|NO_CONNECTION|Can not get connection error|
|707|NEED_REDIRECTION|Need direction|
+|709|ALL_RETRY_FAILED|All retry failed|
+|710|MIGRATE_REGION_ERROR|Error when migrate region|
+|711|CREATE_REGION_ERROR|Create region error|
+|712|DELETE_REGION_ERROR|Delete region error|
+|713|PARTITION_CACHE_UPDATE_FAIL|Update partition cache failed|
+|714|DESERIALIZE_PIECE_OF_TSFILE_ERROR|Error when deserialize a piece of TsFile|
+|715|CONSENSUS_NOT_INITIALIZED|Consensus is not initialized and cannot provide service|
|800|CONFIG_ERROR|Configuration error|
+|901|DATANODE_ALREADY_REGISTERED|DataNode already registered in cluster |
+|902|CREATE_DATABASE_ERROR|Create Database failed|
+|903|DATABASE_ALREADY_EXISTS|Database already exist|
+|904|NOT_ENOUGH_DATA_NODE|The number of DataNode is not enough|
+|905|ERROR_GLOBAL_CONFIG|Global config in cluster does not consistent|
> All exceptions are refactored in latest version by extracting uniform message into exception classes. Different error codes are added to all exceptions. When an exception is caught and a higher-level exception is thrown, the error code will keep and pass so that users will know the detailed error reason.
A base exception class "ProcessException" is also added to be extended by all exceptions.
diff --git a/docs/zh/UserGuide/API/Status-Codes.md b/docs/zh/UserGuide/API/Status-Codes.md
index d055908e68..6a36975cec 100644
--- a/docs/zh/UserGuide/API/Status-Codes.md
+++ b/docs/zh/UserGuide/API/Status-Codes.md
@@ -85,6 +85,27 @@ try {
|334|CREATE_PIPE_SINK_ERROR| 创建 PIPE Sink 异常 |
|335|PIPE_ERROR| PIPE 异常 |
|336|PIPESERVER_ERROR| PIPE server 异常 |
+|337|SERIES_OVERFLOW| 序列数量超过阈值 |
+|338|MEASUREMENT_ALREADY_EXIST| 序列数量超过阈值 |
+|339|TEMPLATE_NOT_EXIST| 物理量模板不存在 |
+|340|CREATE_TEMPLATE_ERROR| 创建物理量模板失败 |
+|341|SYNC_FILE_REBASE| 同步文件异常 |
+|342|SYNC_FILE_ERROR| 同步文件异常 |
+|343|VERIFY_METADATA_ERROR| 校验元数据失败 |
+|344|TIMESERIES_IN_BLACK_LIST| 时间序列正在删除 |
+|349|OVERSIZE_RECORD| 记录大小超过元数据文件页面大小 |
+|350|SCHEMA_FILE_REDO_LOG_BROKEN| SchemaFile 的 redo 日志损坏 |
+|355|TRIGGER_FIRE_ERROR| 触发器执行错误 |
+|360|TRIGGER_LOAD_CLASS_ERROR| 触发器加载类异常 |
+|361|TRIGGER_DOWNLOAD_ERROR| 从 ConfigNode 下载触发器异常 |
+|362|CREATE_TRIGGER_INSTANCE_ERROR| 创建触发器实例异常 |
+|363|ACTIVE_TRIGGER_INSTANCE_ERROR| 激活触发器实例异常 |
+|364|DROP_TRIGGER_INSTANCE_ERROR| 删除触发器实例异常 |
+|365|UPDATE_TRIGGER_LOCATION_ERROR| 更新有状态的触发器所在 DataNode 异常 |
+|370|UDF_LOAD_CLASS_ERROR| UDF 加载类异常 |
+|371|UDF_DOWNLOAD_ERROR| 无法从 ConfigNode 下载 UDF |
+|372|CREATE_FUNCTION_ON_DATANODE_ERROR| 在 DataNode 创建 UDF 失败 |
+|373|DROP_FUNCTION_ON_DATANODE_ERROR| 在 DataNode 卸载 UDF 失败 |
|400|EXECUTE_STATEMENT_ERROR|执行语句错误|
|401|SQL_PARSE_ERROR|SQL 语句分析错误|
|402|GENERATE_TIME_ZONE_ERROR|生成时区错误|
@@ -100,6 +121,10 @@ try {
|412|WRITE_PROCESS_ERROR|写入相关错误|
|413|WRITE_PROCESS_REJECT|写入拒绝错误|
|414|QUERY_ID_NOT_EXIST|Query id 不存在|
+|415|SNAPSHOT_DIR_NOT_LEGAL|快照目录名不合法|
+|416|SEMANTIC_ERROR|SQL 语义错误|
+|417|LOAD_PIECE_OF_TSFILE_ERROR|加载 TsFile 片段异常|
+|423|MEMORY_NOT_ENOUGH|MPP 框架中任务执行内存不足|
|500|INTERNAL_SERVER_ERROR|服务器内部错误|
|501|CLOSE_OPERATION_ERROR|关闭操作错误|
|502|READ_ONLY_SYSTEM_ERROR|系统只读|
@@ -108,19 +133,36 @@ try {
|505|SHUT_DOWN_ERROR|关机错误|
|506|MULTIPLE_ERROR|多行语句执行错误|
|507|SESSION_EXPIRED|会话过期|
+|508|TSBLOCK_SERIALIZE_ERROR|TsBlock 序列化错误|
|600|WRONG_LOGIN_PASSWORD_ERROR|用户名或密码错误|
|601|NOT_LOGIN_ERROR|没有登录|
|602|NO_PERMISSION_ERROR|没有操作权限|
|603|UNINITIALIZED_AUTH_ERROR|授权人未初始化|
+|604|EXECUTE_PERMISSION_EXCEPTION_ERROR||
+|605|USER_NOT_EXIST_ERROR|用户不存在|
+|606|ROLE_NOT_EXIST_ERROR|角色不存在|
+|607|AUTHENTICATION_ERROR|权限认证失败|
+|608|CLEAR_PERMISSION_CACHE_ERROR|清空权限缓存失败|
+
|700|PARTITION_NOT_READY|分区表未准备好|
|701|TIME_OUT|操作超时|
|702|NO_LEADER|Leader 找不到|
|703|UNSUPPORTED_OPERATION|不支持的操作|
-|704|NODE_READ_ONLY|节点只读|
-|705|CONSISTENCY_FAILURE|一致性检查失败|
|706|NO_CONNECTION|连接获取失败|
|707|NEED_REDIRECTION|需要重定向|
+|709|ALL_RETRY_FAILED|所有重试失败|
+|710|MIGRATE_REGION_ERROR|Region 迁移失败|
+|711|CREATE_REGION_ERROR|创建 region 失败|
+|712|DELETE_REGION_ERROR|删除 region 失败|
+|713|PARTITION_CACHE_UPDATE_FAIL|更新分区缓存失败|
+|714|DESERIALIZE_PIECE_OF_TSFILE_ERROR|反序列化 TsFile 片段异常|
+|715|CONSENSUS_NOT_INITIALIZED|共识层未初始化，不能提供服务|
|800|CONFIG_ERROR|配置文件有错误项|
+|901|DATANODE_ALREADY_REGISTERED|DataNode 在集群中已经注册|
+|902|CREATE_DATABASE_ERROR|创建 Database 失败|
+|903|DATABASE_ALREADY_EXISTS|Database 已存在|
+|904|NOT_ENOUGH_DATA_NODE|没有足够的 DataNode|
+|905|ERROR_GLOBAL_CONFIG|全局配置参数异常|
> 在最新版本中，我们重构了 IoTDB 的异常类。通过将错误信息统一提取到异常类中，并为所有异常添加不同的错误代码，从而当捕获到异常并引发更高级别的异常时，错误代码将保留并传递，以便用户了解详细的错误原因。
除此之外，我们添加了一个基础异常类“ProcessException”，由所有异常扩展。
diff --git a/integration-test/src/test/java/org/apache/iotdb/confignode/it/IoTDBStorageGroupIT.java b/integration-test/src/test/java/org/apache/iotdb/confignode/it/IoTDBStorageGroupIT.java
index 6867a42d44..0010a56420 100644
--- a/integration-test/src/test/java/org/apache/iotdb/confignode/it/IoTDBStorageGroupIT.java
+++ b/integration-test/src/test/java/org/apache/iotdb/confignode/it/IoTDBStorageGroupIT.java
@@ -126,8 +126,7 @@ public class IoTDBStorageGroupIT {
// test fail by re-register
status = client.setStorageGroup(setReq0);
- Assert.assertEquals(
- TSStatusCode.STORAGE_GROUP_ALREADY_EXISTS.getStatusCode(), status.getCode());
+ Assert.assertEquals(TSStatusCode.DATABASE_ALREADY_EXISTS.getStatusCode(), status.getCode());
// test StorageGroup setter interfaces
PartialPath patternPath = new PartialPath(sg1);
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 d2e3ed2035..06d6ed3246 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
@@ -78,7 +78,6 @@ public class StatusUtils {
case PATH_ALREADY_EXIST_ERROR:
status.setMessage("Path already exist.");
break;
- case PATH_NOT_EXIST_ERROR:
case PATH_NOT_EXIST_ERROR:
status.setMessage("Path does not exist.");
break;
@@ -190,9 +189,6 @@ public class StatusUtils {
case NO_CONNECTION:
status.setMessage("Node cannot be reached.");
break;
- case PARSE_LOG_ERROR:
- status.setMessage("Parse log error.");
- break;
default:
status.setMessage("");
break;
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 30c6f2500b..4ee0c4437a 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
@@ -715,7 +715,7 @@ public class StorageEngineV2 implements IService {
"Parse Page error when writing piece node of TsFile %s to DataRegion %s.",
pieceNode.getTsFile(), dataRegionId),
e);
- status.setCode(TSStatusCode.TSFILE_RUNTIME_ERROR.getStatusCode());
+ status.setCode(TSStatusCode.LOAD_PIECE_OF_TSFILE_ERROR.getStatusCode());
status.setMessage(e.getMessage());
return status;
} catch (IOException e) {
diff --git a/server/src/main/java/org/apache/iotdb/db/exception/metadata/MeasurementAlreadyExistException.java b/server/src/main/java/org/apache/iotdb/db/exception/metadata/MeasurementAlreadyExistException.java
index c5a9afbc68..9ff7116d71 100644
--- a/server/src/main/java/org/apache/iotdb/db/exception/metadata/MeasurementAlreadyExistException.java
+++ b/server/src/main/java/org/apache/iotdb/db/exception/metadata/MeasurementAlreadyExistException.java
@@ -31,7 +31,7 @@ public class MeasurementAlreadyExistException extends MetadataException {
public MeasurementAlreadyExistException(String path, MeasurementPath measurementPath) {
super(
String.format("Path [%s] already exist", path),
- TSStatusCode.MEASUREMENT_ALREADY_EXIST.getStatusCode());
+ TSStatusCode.TIMESERIES_ALREADY_EXIST.getStatusCode());
this.isUserException = true;
this.measurementPath = measurementPath;
}
diff --git a/server/src/main/java/org/apache/iotdb/db/exception/metadata/MeasurementInBlackListException.java b/server/src/main/java/org/apache/iotdb/db/exception/metadata/MeasurementInBlackListException.java
index 3aef42cec0..d6dd5c3cab 100644
--- a/server/src/main/java/org/apache/iotdb/db/exception/metadata/MeasurementInBlackListException.java
+++ b/server/src/main/java/org/apache/iotdb/db/exception/metadata/MeasurementInBlackListException.java
@@ -31,7 +31,7 @@ public class MeasurementInBlackListException extends MetadataException {
public MeasurementInBlackListException(PartialPath path) {
super(
String.format("Some task is deleting timeseries [%s]", path),
- TSStatusCode.MEASUREMENT_IN_BLACK_LIST.getStatusCode());
+ TSStatusCode.TIMESERIES_IN_BLACK_LIST.getStatusCode());
this.path = path;
}
diff --git a/server/src/main/java/org/apache/iotdb/db/exception/metadata/StorageGroupAlreadySetException.java b/server/src/main/java/org/apache/iotdb/db/exception/metadata/StorageGroupAlreadySetException.java
index 9529bbf904..89aacde85d 100644
--- a/server/src/main/java/org/apache/iotdb/db/exception/metadata/StorageGroupAlreadySetException.java
+++ b/server/src/main/java/org/apache/iotdb/db/exception/metadata/StorageGroupAlreadySetException.java
@@ -31,13 +31,13 @@ public class StorageGroupAlreadySetException extends MetadataException {
private final String storageGroupPath;
public StorageGroupAlreadySetException(String path) {
- super(getMessage(path, false), TSStatusCode.STORAGE_GROUP_ALREADY_EXISTS.getStatusCode());
+ super(getMessage(path, false), TSStatusCode.DATABASE_ALREADY_EXISTS.getStatusCode());
storageGroupPath = path;
hasChild = false;
}
public StorageGroupAlreadySetException(String path, boolean hasChild) {
- super(getMessage(path, hasChild), TSStatusCode.STORAGE_GROUP_ALREADY_EXISTS.getStatusCode());
+ super(getMessage(path, hasChild), TSStatusCode.DATABASE_ALREADY_EXISTS.getStatusCode());
this.hasChild = hasChild;
storageGroupPath = path;
}
diff --git a/server/src/main/java/org/apache/iotdb/db/exception/metadata/schemafile/ColossalRecordException.java b/server/src/main/java/org/apache/iotdb/db/exception/metadata/schemafile/ColossalRecordException.java
index 39f1968ab7..96777d38ef 100644
--- a/server/src/main/java/org/apache/iotdb/db/exception/metadata/schemafile/ColossalRecordException.java
+++ b/server/src/main/java/org/apache/iotdb/db/exception/metadata/schemafile/ColossalRecordException.java
@@ -33,21 +33,21 @@ public class ColossalRecordException extends MetadataException {
super(
String.format(
"Record of key [%s] is too large for SchemaFile to store, content size:%d", key, size),
- TSStatusCode.COLOSSAL_RECORD.getStatusCode(),
+ TSStatusCode.OVERSIZE_RECORD.getStatusCode(),
true);
}
public ColossalRecordException(String key) {
super(
String.format("Key [%s] is too large to store in a InternalPage as index entry.", key),
- TSStatusCode.COLOSSAL_RECORD.getStatusCode(),
+ TSStatusCode.OVERSIZE_RECORD.getStatusCode(),
true);
}
public ColossalRecordException(String key, String alias) {
super(
String.format("Key-Alias pair (%s, %s) is too large for SchemaFile to store.", key, alias),
- TSStatusCode.COLOSSAL_RECORD.getStatusCode(),
+ TSStatusCode.OVERSIZE_RECORD.getStatusCode(),
true);
}
}
diff --git a/server/src/main/java/org/apache/iotdb/db/exception/metadata/schemafile/SchemaFileLogCorruptedException.java b/server/src/main/java/org/apache/iotdb/db/exception/metadata/schemafile/SchemaFileLogCorruptedException.java
index 47b67f34d5..fab2200350 100644
--- a/server/src/main/java/org/apache/iotdb/db/exception/metadata/schemafile/SchemaFileLogCorruptedException.java
+++ b/server/src/main/java/org/apache/iotdb/db/exception/metadata/schemafile/SchemaFileLogCorruptedException.java
@@ -28,7 +28,7 @@ public class SchemaFileLogCorruptedException extends MetadataException {
public SchemaFileLogCorruptedException(String fileName, String reason) {
super(
String.format("SchemaFileLog [%s] corrupted for [%s].", fileName, reason),
- TSStatusCode.SCHEMA_FILE_LOG_CORR.getStatusCode(),
+ TSStatusCode.SCHEMA_FILE_REDO_LOG_BROKEN.getStatusCode(),
true);
}
}
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/execution/executor/RegionWriteExecutor.java b/server/src/main/java/org/apache/iotdb/db/mpp/execution/executor/RegionWriteExecutor.java
index 72811cc815..d017491141 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/executor/RegionWriteExecutor.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/executor/RegionWriteExecutor.java
@@ -422,7 +422,7 @@ public class RegionWriteExecutor {
failingMeasurementMap.entrySet()) {
metadataException = failingMeasurement.getValue();
if (metadataException.getErrorCode()
- == TSStatusCode.MEASUREMENT_ALREADY_EXIST.getStatusCode()) {
+ == TSStatusCode.TIMESERIES_ALREADY_EXIST.getStatusCode()) {
LOGGER.info(
"There's no need to internal create timeseries. {}",
failingMeasurement.getValue().getMessage());
@@ -452,7 +452,7 @@ public class RegionWriteExecutor {
if (failingStatus.isEmpty()) {
if (executionStatus.getCode() == TSStatusCode.MULTIPLE_ERROR.getStatusCode()) {
if (executionStatus.getSubStatus().get(0).getCode()
- == TSStatusCode.MEASUREMENT_ALREADY_EXIST.getStatusCode()) {
+ == TSStatusCode.TIMESERIES_ALREADY_EXIST.getStatusCode()) {
// there's only measurement_already_exist exception
alreadyExistingStatus.addAll(executionStatus.getSubStatus());
} else {
@@ -464,7 +464,7 @@ public class RegionWriteExecutor {
} else {
if (executionStatus.getCode() == TSStatusCode.MULTIPLE_ERROR.getStatusCode()) {
if (executionStatus.getSubStatus().get(0).getCode()
- != TSStatusCode.MEASUREMENT_ALREADY_EXIST.getStatusCode()) {
+ != TSStatusCode.TIMESERIES_ALREADY_EXIST.getStatusCode()) {
failingStatus.addAll(executionStatus.getSubStatus());
}
} else if (executionStatus.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java
index 66520cc651..3d409e42ea 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java
@@ -1734,7 +1734,7 @@ public class AnalyzeVisitor extends StatementVisitor<Analysis, MPPQueryContext>
schemaFetcher,
IoTDBDescriptor.getInstance().getConfig().getQueryTimeoutThreshold());
if (result.status.code != TSStatusCode.SUCCESS_STATUS.getStatusCode()
- && result.status.code != TSStatusCode.STORAGE_GROUP_ALREADY_EXISTS.getStatusCode()) {
+ && result.status.code != TSStatusCode.DATABASE_ALREADY_EXISTS.getStatusCode()) {
logger.error(String.format("Create Database error, statement: %s.", statement));
logger.error(String.format("Create database result status : %s.", result.status));
throw new LoadFileException(
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/ClusterSchemaFetcher.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/ClusterSchemaFetcher.java
index 22964f5ad4..b11ed72317 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/ClusterSchemaFetcher.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/ClusterSchemaFetcher.java
@@ -488,7 +488,7 @@ public class ClusterSchemaFetcher implements ISchemaFetcher {
List<String> failedCreationList = new ArrayList<>();
List<MeasurementPath> alreadyExistingMeasurements = new ArrayList<>();
for (TSStatus subStatus : executionResult.status.subStatus) {
- if (subStatus.code == TSStatusCode.MEASUREMENT_ALREADY_EXIST.getStatusCode()) {
+ if (subStatus.code == TSStatusCode.TIMESERIES_ALREADY_EXIST.getStatusCode()) {
alreadyExistingMeasurements.add(
MeasurementPath.parseDataFromString(subStatus.getMessage()));
} else {
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/executor/ClusterConfigTaskExecutor.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/executor/ClusterConfigTaskExecutor.java
index 43981a2848..706c54935e 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/executor/ClusterConfigTaskExecutor.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/executor/ClusterConfigTaskExecutor.java
@@ -521,7 +521,7 @@ public class ClusterConfigTaskExecutor implements IConfigTaskExecutor {
+ createTriggerStatement.getClassName()
+ "', because it's not found in jar file: "
+ createTriggerStatement.getUriString(),
- TSStatusCode.TRIGGER_LOAD_CLASS.getStatusCode()));
+ TSStatusCode.TRIGGER_LOAD_CLASS_ERROR.getStatusCode()));
return future;
}
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/load/LoadTsFileDispatcherImpl.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/load/LoadTsFileDispatcherImpl.java
index 3471aa3563..e684564094 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/load/LoadTsFileDispatcherImpl.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/load/LoadTsFileDispatcherImpl.java
@@ -157,7 +157,7 @@ public class LoadTsFileDispatcherImpl implements IFragInstanceDispatcher {
(LoadTsFilePieceNode) PlanNodeType.deserialize(planNode.serializeToByteBuffer());
if (pieceNode == null) {
throw new FragmentInstanceDispatchException(
- new TSStatus(TSStatusCode.NODE_DESERIALIZE_ERROR.getStatusCode()));
+ new TSStatus(TSStatusCode.DESERIALIZE_PIECE_OF_TSFILE_ERROR.getStatusCode()));
}
TSStatus resultStatus =
StorageEngineV2.getInstance()
diff --git a/server/src/main/java/org/apache/iotdb/db/protocol/influxdb/meta/NewInfluxDBMetaManager.java b/server/src/main/java/org/apache/iotdb/db/protocol/influxdb/meta/NewInfluxDBMetaManager.java
index 2f5422b034..7992a70000 100644
--- a/server/src/main/java/org/apache/iotdb/db/protocol/influxdb/meta/NewInfluxDBMetaManager.java
+++ b/server/src/main/java/org/apache/iotdb/db/protocol/influxdb/meta/NewInfluxDBMetaManager.java
@@ -118,7 +118,7 @@ public class NewInfluxDBMetaManager extends AbstractInfluxDBMetaManager {
public void setStorageGroup(String database, long sessionID) {
TSStatus status = clientRPCService.setStorageGroup(sessionID, "root." + database);
if (status.getCode() == TSStatusCode.SUCCESS_STATUS.getStatusCode()
- || status.getCode() == TSStatusCode.STORAGE_GROUP_ALREADY_EXISTS.getStatusCode()) {
+ || status.getCode() == TSStatusCode.DATABASE_ALREADY_EXISTS.getStatusCode()) {
return;
}
throw new InfluxDBException(status.getMessage());
diff --git a/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/DataNodeInternalRPCServiceImpl.java b/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/DataNodeInternalRPCServiceImpl.java
index f691488eb6..566cc15caa 100644
--- a/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/DataNodeInternalRPCServiceImpl.java
+++ b/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/DataNodeInternalRPCServiceImpl.java
@@ -347,7 +347,8 @@ public class DataNodeInternalRPCServiceImpl implements IDataNodeRPCService.Iface
ConsensusGroupId.Factory.createFromTConsensusGroupId(req.consensusGroupId);
LoadTsFilePieceNode pieceNode = (LoadTsFilePieceNode) PlanNodeType.deserialize(req.body);
if (pieceNode == null) {
- return createTLoadResp(new TSStatus(TSStatusCode.NODE_DESERIALIZE_ERROR.getStatusCode()));
+ return createTLoadResp(
+ new TSStatus(TSStatusCode.DESERIALIZE_PIECE_OF_TSFILE_ERROR.getStatusCode()));
}
TSStatus resultStatus =
@@ -971,7 +972,7 @@ public class DataNodeInternalRPCServiceImpl implements IDataNodeRPCService.Iface
if (result) {
return RpcUtils.getStatus(TSStatusCode.SUCCESS_STATUS);
} else {
- return RpcUtils.getStatus(TSStatusCode.CACHE_UPDATE_FAIL);
+ return RpcUtils.getStatus(TSStatusCode.PARTITION_CACHE_UPDATE_FAIL);
}
}
@@ -1063,7 +1064,7 @@ public class DataNodeInternalRPCServiceImpl implements IDataNodeRPCService.Iface
if (AuthorizerManager.getInstance().invalidateCache(req.getUsername(), req.getRoleName())) {
return RpcUtils.getStatus(TSStatusCode.SUCCESS_STATUS);
}
- return RpcUtils.getStatus(TSStatusCode.INVALIDATE_PERMISSION_CACHE_ERROR);
+ return RpcUtils.getStatus(TSStatusCode.CLEAR_PERMISSION_CACHE_ERROR);
}
@Override
diff --git a/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/NewInfluxDBServiceImpl.java b/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/NewInfluxDBServiceImpl.java
index 38a3a4d157..a033c00af9 100644
--- a/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/NewInfluxDBServiceImpl.java
+++ b/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/NewInfluxDBServiceImpl.java
@@ -137,7 +137,7 @@ public class NewInfluxDBServiceImpl implements IInfluxDBServiceWithHandler {
public InfluxTSStatus createDatabase(InfluxCreateDatabaseReq req) {
TSStatus tsStatus =
clientRPCService.setStorageGroup(req.sessionId, "root." + req.getDatabase());
- if (tsStatus.getCode() == TSStatusCode.STORAGE_GROUP_ALREADY_EXISTS.getStatusCode()) {
+ if (tsStatus.getCode() == TSStatusCode.DATABASE_ALREADY_EXISTS.getStatusCode()) {
tsStatus.setCode(TSStatusCode.SUCCESS_STATUS.getStatusCode());
tsStatus.setMessage("Execute successfully");
}
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 2abc593f8d..0230e6a804 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
@@ -65,17 +65,17 @@ public enum TSStatusCode {
PIPE_ERROR(335),
PIPESERVER_ERROR(336),
SERIES_OVERFLOW(337),
- MEASUREMENT_ALREADY_EXIST(338),
+ TIMESERIES_ALREADY_EXIST(338),
TEMPLATE_NOT_EXIST(339),
CREATE_TEMPLATE_ERROR(340),
SYNC_FILE_REBASE(341),
SYNC_FILE_ERROR(342),
VERIFY_METADATA_ERROR(343),
- MEASUREMENT_IN_BLACK_LIST(344),
- COLOSSAL_RECORD(349),
- SCHEMA_FILE_LOG_CORR(350),
+ TIMESERIES_IN_BLACK_LIST(344),
+ OVERSIZE_RECORD(349),
+ SCHEMA_FILE_REDO_LOG_BROKEN(350),
TRIGGER_FIRE_ERROR(355),
- TRIGGER_LOAD_CLASS(360),
+ TRIGGER_LOAD_CLASS_ERROR(360),
TRIGGER_DOWNLOAD_ERROR(361),
CREATE_TRIGGER_INSTANCE_ERROR(362),
ACTIVE_TRIGGER_INSTANCE_ERROR(363),
@@ -104,9 +104,8 @@ public enum TSStatusCode {
QUERY_ID_NOT_EXIST(414),
SNAPSHOT_DIR_NOT_LEGAL(415),
SEMANTIC_ERROR(416),
- TSFILE_RUNTIME_ERROR(417),
+ LOAD_PIECE_OF_TSFILE_ERROR(417),
- UNSUPPORTED_INDEX_FUNC_ERROR(421),
UNSUPPORTED_INDEX_TYPE_ERROR(422),
MEMORY_NOT_ENOUGH(423),
@@ -125,11 +124,11 @@ public enum TSStatusCode {
NOT_LOGIN_ERROR(601),
NO_PERMISSION_ERROR(602),
UNINITIALIZED_AUTH_ERROR(603),
- EXECUTE_PERMISSION_EXCEPTION_ERROR(604),
+ EXECUTE_PERMISSION_ERROR(604),
USER_NOT_EXIST_ERROR(605),
ROLE_NOT_EXIST_ERROR(606),
AUTHENTICATION_ERROR(607),
- INVALIDATE_PERMISSION_CACHE_ERROR(608),
+ CLEAR_PERMISSION_CACHE_ERROR(608),
// cluster-related errors
PARTITION_NOT_READY(700),
@@ -138,13 +137,12 @@ public enum TSStatusCode {
UNSUPPORTED_OPERATION(703),
NO_CONNECTION(706),
NEED_REDIRECTION(707),
- PARSE_LOG_ERROR(708),
ALL_RETRY_FAILED(709),
MIGRATE_REGION_ERROR(710),
CREATE_REGION_ERROR(711),
DELETE_REGION_ERROR(712),
- CACHE_UPDATE_FAIL(713),
- NODE_DESERIALIZE_ERROR(714),
+ PARTITION_CACHE_UPDATE_FAIL(713),
+ DESERIALIZE_PIECE_OF_TSFILE_ERROR(714),
CONSENSUS_NOT_INITIALIZED(715),
// configuration
@@ -152,8 +150,8 @@ public enum TSStatusCode {
// ConfigNode response
DATANODE_ALREADY_REGISTERED(901),
- SET_STORAGE_GROUP_FAILED(902),
- STORAGE_GROUP_ALREADY_EXISTS(903),
+ CREATE_DATABASE_ERROR(902),
+ DATABASE_ALREADY_EXISTS(903),
NOT_ENOUGH_DATA_NODE(904),
ERROR_GLOBAL_CONFIG(905),
APPLY_CONFIGNODE_FAILED(906),
[iotdb] 01/02: fix some status code
Posted by qi...@apache.org.
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),