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 <[email protected]> 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),
