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/17 05:43:09 UTC
[iotdb] branch adjust_error_code created (now b0053f7e54)
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a change to branch adjust_error_code
in repository https://gitbox.apache.org/repos/asf/iotdb.git
at b0053f7e54 adjust error code
This branch includes the following new commits:
new b0053f7e54 adjust error code
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[iotdb] 01/01: adjust error code
Posted by qi...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a commit to branch adjust_error_code
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit b0053f7e54b2e231946aadaa7e452cd06aa7e0da
Author: qiaojialin <64...@qq.com>
AuthorDate: Thu Nov 17 13:42:53 2022 +0800
adjust error code
---
.../client/sync/SyncConfigNodeClientPool.java | 5 +-
.../client/sync/SyncDataNodeClientPool.java | 6 +-
...n.java => NoAvailableRegionGroupException.java} | 4 +-
.../confignode/manager/ClusterSchemaManager.java | 2 +-
.../iotdb/confignode/manager/ConfigManager.java | 2 +-
.../iotdb/confignode/manager/ConsensusManager.java | 2 +-
.../iotdb/confignode/manager/ProcedureManager.java | 2 +-
.../iotdb/confignode/manager/load/LoadManager.java | 6 +-
.../manager/load/balancer/PartitionBalancer.java | 6 +-
.../partition/GreedyPartitionAllocator.java | 6 +-
.../balancer/partition/IPartitionAllocator.java | 6 +-
.../iotdb/confignode/manager/node/NodeManager.java | 6 +-
.../manager/partition/PartitionManager.java | 18 +-
.../iotdb/confignode/persistence/AuthorInfo.java | 4 +-
.../iotdb/confignode/service/ConfigNode.java | 4 +-
.../multileader/MultiLeaderConsensus.java | 2 +-
.../multileader/client/DispatchLogHandler.java | 2 +-
.../service/MultiLeaderRPCServiceProcessor.java | 2 +-
.../iotdb/consensus/simple/SimpleConsensus.java | 2 +-
docs/UserGuide/API/Status-Codes.md | 149 +++++------
docs/zh/UserGuide/API/Status-Codes.md | 152 ++++++------
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 26 +-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 4 +-
.../commons/exception/IllegalPathException.java | 4 +-
.../apache/iotdb/commons/utils/StatusUtils.java | 17 +-
.../iotdb/db/auth/StandaloneAuthorityFetcher.java | 2 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 2 +-
.../apache/iotdb/db/engine/StorageEngineV2.java | 8 +-
.../db/exception/ContinuousQueryException.java | 36 ---
.../iotdb/db/exception/DataRegionException.java | 4 +-
.../exception/StorageEngineReadonlyException.java | 2 +-
.../iotdb/db/exception/SystemCheckException.java | 34 ---
.../index/UnsupportedIndexTypeException.java | 32 ---
.../exception/metadata/DeleteFailedException.java | 40 ---
.../apache/iotdb/db/index/common/IndexType.java | 10 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 16 +-
.../schemaregion/SchemaRegionSchemaFileImpl.java | 16 +-
.../operator/process/AbstractIntoOperator.java | 2 +-
.../db/mpp/plan/execution/QueryExecution.java | 5 +-
.../config/executor/ClusterConfigTaskExecutor.java | 12 +-
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 2 +-
.../db/mpp/plan/scheduler/StandaloneScheduler.java | 2 +-
.../protocol/rest/filter/AuthorizationFilter.java | 4 +-
.../protocol/rest/impl/GrafanaApiServiceImpl.java | 6 +-
.../db/protocol/rest/impl/RestApiServiceImpl.java | 6 +-
.../iotdb/db/query/control/SessionManager.java | 2 +-
.../service/thrift/impl/ClientRPCServiceImpl.java | 4 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 6 +-
.../service/thrift/impl/DataNodeRegionManager.java | 2 +-
.../db/service/thrift/impl/TSServiceImpl.java | 2 +-
.../java/org/apache/iotdb/db/tools/WalChecker.java | 10 +-
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 8 +-
.../iotdb/db/wal/exception/WALException.java | 6 +-
.../org/apache/iotdb/db/tools/WalCheckerTest.java | 12 +-
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 8 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 271 +++++++++++----------
56 files changed, 438 insertions(+), 573 deletions(-)
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/client/sync/SyncConfigNodeClientPool.java b/confignode/src/main/java/org/apache/iotdb/confignode/client/sync/SyncConfigNodeClientPool.java
index 99fe08b702..e7e322e1f6 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/client/sync/SyncConfigNodeClientPool.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/client/sync/SyncConfigNodeClientPool.java
@@ -102,7 +102,8 @@ public class SyncConfigNodeClientPool {
}
LOGGER.error("{} failed on ConfigNode {}", requestType, endPoint, lastException);
return RpcUtils.getStatus(
- TSStatusCode.ALL_RETRY_ERROR, "All retry failed due to: " + lastException.getMessage());
+ TSStatusCode.INTERNAL_REQUEST_RETRY_ERROR,
+ "All retry failed due to: " + lastException.getMessage());
}
/**
@@ -115,7 +116,7 @@ public class SyncConfigNodeClientPool {
TConfigNodeLocation configNodeLocation, SyncConfigNodeIServiceClient client)
throws TException, IOException, InterruptedException {
TSStatus status = client.removeConfigNode(configNodeLocation);
- while (status.getCode() == TSStatusCode.NEED_REDIRECTION.getStatusCode()) {
+ while (status.getCode() == TSStatusCode.REDIRECTION_RECOMMEND.getStatusCode()) {
TimeUnit.MILLISECONDS.sleep(2000);
updateConfigNodeLeader(status);
try (SyncConfigNodeIServiceClient clientLeader =
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/client/sync/SyncDataNodeClientPool.java b/confignode/src/main/java/org/apache/iotdb/confignode/client/sync/SyncDataNodeClientPool.java
index 5d5c5c6bb1..ec2de81350 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/client/sync/SyncDataNodeClientPool.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/client/sync/SyncDataNodeClientPool.java
@@ -81,7 +81,7 @@ public class SyncDataNodeClientPool {
}
}
LOGGER.error("{} failed on DataNode {}", requestType, endPoint, lastException);
- return new TSStatus(TSStatusCode.ALL_RETRY_ERROR.getStatusCode())
+ return new TSStatus(TSStatusCode.INTERNAL_REQUEST_RETRY_ERROR.getStatusCode())
.setMessage("All retry failed due to: " + lastException.getMessage());
}
@@ -105,7 +105,7 @@ public class SyncDataNodeClientPool {
}
}
LOGGER.error("{} failed on DataNode {}", requestType, endPoint, lastException);
- return new TSStatus(TSStatusCode.ALL_RETRY_ERROR.getStatusCode())
+ return new TSStatus(TSStatusCode.INTERNAL_REQUEST_RETRY_ERROR.getStatusCode())
.setMessage("All retry failed due to: " + lastException.getMessage());
}
@@ -179,7 +179,7 @@ public class SyncDataNodeClientPool {
status = client.changeRegionLeader(req);
} catch (IOException e) {
LOGGER.error("Can't connect to Data node: {}", dataNode, e);
- status = new TSStatus(TSStatusCode.NO_CONNECTION.getStatusCode());
+ status = new TSStatus(TSStatusCode.CAN_NOT_CONNECT_DATANODE.getStatusCode());
status.setMessage(e.getMessage());
} catch (TException e) {
LOGGER.error("Change regions leader error on Date node: {}", dataNode, e);
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/exception/NotAvailableRegionGroupException.java b/confignode/src/main/java/org/apache/iotdb/confignode/exception/NoAvailableRegionGroupException.java
similarity index 88%
rename from confignode/src/main/java/org/apache/iotdb/confignode/exception/NotAvailableRegionGroupException.java
rename to confignode/src/main/java/org/apache/iotdb/confignode/exception/NoAvailableRegionGroupException.java
index a9687a804f..294c06d390 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/exception/NotAvailableRegionGroupException.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/exception/NoAvailableRegionGroupException.java
@@ -18,9 +18,9 @@
*/
package org.apache.iotdb.confignode.exception;
-public class NotAvailableRegionGroupException extends ConfigNodeException {
+public class NoAvailableRegionGroupException extends ConfigNodeException {
- public NotAvailableRegionGroupException() {
+ public NoAvailableRegionGroupException() {
super(
"There are no available RegionGroups currently, please check the status of cluster DataNodes");
}
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 008bb69b11..2566317627 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
@@ -123,7 +123,7 @@ public class ClusterSchemaManager {
} catch (MetadataException metadataException) {
// Reject if StorageGroup already set
if (metadataException instanceof IllegalPathException) {
- result = new TSStatus(TSStatusCode.PATH_ILLEGAL.getStatusCode());
+ result = new TSStatus(TSStatusCode.ILLEGAL_PATH.getStatusCode());
} else {
result = new TSStatus(TSStatusCode.DATABASE_ALREADY_EXISTS.getStatusCode());
}
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 747a5c00f2..178ec1be95 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
@@ -736,7 +736,7 @@ public class ConfigManager implements IManager {
final String errorSuffix = " is consistent with the Seed-ConfigNode.";
ConfigNodeConfig conf = ConfigNodeDescriptor.getInstance().getConf();
- TSStatus errorStatus = new TSStatus(TSStatusCode.ERROR_GLOBAL_CONFIG.getStatusCode());
+ TSStatus errorStatus = new TSStatus(TSStatusCode.CONFIGURATION_ERROR.getStatusCode());
if (!req.getDataRegionConsensusProtocolClass()
.equals(conf.getDataRegionConsensusProtocolClass())) {
return errorStatus.setMessage(
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConsensusManager.java b/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConsensusManager.java
index 446d745b20..3de783f000 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConsensusManager.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConsensusManager.java
@@ -328,7 +328,7 @@ public class ConsensusManager {
if (isLeader()) {
return result.setCode(TSStatusCode.SUCCESS_STATUS.getStatusCode());
} else {
- result.setCode(TSStatusCode.NEED_REDIRECTION.getStatusCode());
+ result.setCode(TSStatusCode.REDIRECTION_RECOMMEND.getStatusCode());
result.setMessage(
"The current ConfigNode is not leader, please redirect to a new ConfigNode.");
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/manager/ProcedureManager.java b/confignode/src/main/java/org/apache/iotdb/confignode/manager/ProcedureManager.java
index 79ecc64828..9e42c753c0 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/manager/ProcedureManager.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/manager/ProcedureManager.java
@@ -501,7 +501,7 @@ public class ProcedureManager {
executor.getResultOrProcedure(procedureId);
if (!finishedProcedure.isFinished()) {
// the procedure is still executing
- statusList.add(RpcUtils.getStatus(TSStatusCode.STILL_EXECUTING_STATUS));
+ statusList.add(RpcUtils.getStatus(TSStatusCode.OVERLAP_WITH_EXISTING_TASK));
isSucceed = false;
continue;
}
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/LoadManager.java b/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/LoadManager.java
index ed8564617c..b16692e8db 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/LoadManager.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/LoadManager.java
@@ -37,7 +37,7 @@ import org.apache.iotdb.confignode.client.async.handlers.AsyncClientHandler;
import org.apache.iotdb.confignode.conf.ConfigNodeConfig;
import org.apache.iotdb.confignode.conf.ConfigNodeDescriptor;
import org.apache.iotdb.confignode.consensus.request.write.region.CreateRegionGroupsPlan;
-import org.apache.iotdb.confignode.exception.NotAvailableRegionGroupException;
+import org.apache.iotdb.confignode.exception.NoAvailableRegionGroupException;
import org.apache.iotdb.confignode.exception.NotEnoughDataNodeException;
import org.apache.iotdb.confignode.exception.StorageGroupNotExistsException;
import org.apache.iotdb.confignode.manager.ClusterSchemaManager;
@@ -123,7 +123,7 @@ public class LoadManager {
*/
public Map<String, SchemaPartitionTable> allocateSchemaPartition(
Map<String, List<TSeriesPartitionSlot>> unassignedSchemaPartitionSlotsMap)
- throws NotAvailableRegionGroupException {
+ throws NoAvailableRegionGroupException {
return partitionBalancer.allocateSchemaPartition(unassignedSchemaPartitionSlotsMap);
}
@@ -136,7 +136,7 @@ public class LoadManager {
public Map<String, DataPartitionTable> allocateDataPartition(
Map<String, Map<TSeriesPartitionSlot, List<TTimePartitionSlot>>>
unassignedDataPartitionSlotsMap)
- throws NotAvailableRegionGroupException {
+ throws NoAvailableRegionGroupException {
return partitionBalancer.allocateDataPartition(unassignedDataPartitionSlotsMap);
}
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/PartitionBalancer.java b/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/PartitionBalancer.java
index f51b0db187..72522e099b 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/PartitionBalancer.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/PartitionBalancer.java
@@ -22,7 +22,7 @@ import org.apache.iotdb.common.rpc.thrift.TSeriesPartitionSlot;
import org.apache.iotdb.common.rpc.thrift.TTimePartitionSlot;
import org.apache.iotdb.commons.partition.DataPartitionTable;
import org.apache.iotdb.commons.partition.SchemaPartitionTable;
-import org.apache.iotdb.confignode.exception.NotAvailableRegionGroupException;
+import org.apache.iotdb.confignode.exception.NoAvailableRegionGroupException;
import org.apache.iotdb.confignode.manager.IManager;
import org.apache.iotdb.confignode.manager.load.balancer.partition.GreedyPartitionAllocator;
import org.apache.iotdb.confignode.manager.load.balancer.partition.IPartitionAllocator;
@@ -50,7 +50,7 @@ public class PartitionBalancer {
*/
public Map<String, SchemaPartitionTable> allocateSchemaPartition(
Map<String, List<TSeriesPartitionSlot>> unassignedSchemaPartitionSlotsMap)
- throws NotAvailableRegionGroupException {
+ throws NoAvailableRegionGroupException {
return genPartitionAllocator().allocateSchemaPartition(unassignedSchemaPartitionSlotsMap);
}
@@ -63,7 +63,7 @@ public class PartitionBalancer {
public Map<String, DataPartitionTable> allocateDataPartition(
Map<String, Map<TSeriesPartitionSlot, List<TTimePartitionSlot>>>
unassignedDataPartitionSlotsMap)
- throws NotAvailableRegionGroupException {
+ throws NoAvailableRegionGroupException {
return genPartitionAllocator().allocateDataPartition(unassignedDataPartitionSlotsMap);
}
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/partition/GreedyPartitionAllocator.java b/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/partition/GreedyPartitionAllocator.java
index 73b5263318..99350f431e 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/partition/GreedyPartitionAllocator.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/partition/GreedyPartitionAllocator.java
@@ -26,7 +26,7 @@ import org.apache.iotdb.commons.partition.DataPartitionTable;
import org.apache.iotdb.commons.partition.SchemaPartitionTable;
import org.apache.iotdb.commons.partition.SeriesPartitionTable;
import org.apache.iotdb.confignode.conf.ConfigNodeDescriptor;
-import org.apache.iotdb.confignode.exception.NotAvailableRegionGroupException;
+import org.apache.iotdb.confignode.exception.NoAvailableRegionGroupException;
import org.apache.iotdb.confignode.manager.IManager;
import org.apache.iotdb.confignode.manager.partition.PartitionManager;
import org.apache.iotdb.tsfile.utils.Pair;
@@ -52,7 +52,7 @@ public class GreedyPartitionAllocator implements IPartitionAllocator {
@Override
public Map<String, SchemaPartitionTable> allocateSchemaPartition(
Map<String, List<TSeriesPartitionSlot>> unassignedSchemaPartitionSlotsMap)
- throws NotAvailableRegionGroupException {
+ throws NoAvailableRegionGroupException {
Map<String, SchemaPartitionTable> result = new ConcurrentHashMap<>();
for (Map.Entry<String, List<TSeriesPartitionSlot>> slotsMapEntry :
@@ -83,7 +83,7 @@ public class GreedyPartitionAllocator implements IPartitionAllocator {
public Map<String, DataPartitionTable> allocateDataPartition(
Map<String, Map<TSeriesPartitionSlot, List<TTimePartitionSlot>>>
unassignedDataPartitionSlotsMap)
- throws NotAvailableRegionGroupException {
+ throws NoAvailableRegionGroupException {
Map<String, DataPartitionTable> result = new ConcurrentHashMap<>();
for (Map.Entry<String, Map<TSeriesPartitionSlot, List<TTimePartitionSlot>>> slotsMapEntry :
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/partition/IPartitionAllocator.java b/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/partition/IPartitionAllocator.java
index f957c0b8db..ec20638d3e 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/partition/IPartitionAllocator.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/partition/IPartitionAllocator.java
@@ -22,7 +22,7 @@ import org.apache.iotdb.common.rpc.thrift.TSeriesPartitionSlot;
import org.apache.iotdb.common.rpc.thrift.TTimePartitionSlot;
import org.apache.iotdb.commons.partition.DataPartitionTable;
import org.apache.iotdb.commons.partition.SchemaPartitionTable;
-import org.apache.iotdb.confignode.exception.NotAvailableRegionGroupException;
+import org.apache.iotdb.confignode.exception.NoAvailableRegionGroupException;
import java.util.List;
import java.util.Map;
@@ -41,7 +41,7 @@ public interface IPartitionAllocator {
*/
Map<String, SchemaPartitionTable> allocateSchemaPartition(
Map<String, List<TSeriesPartitionSlot>> unassignedSchemaPartitionSlotsMap)
- throws NotAvailableRegionGroupException;
+ throws NoAvailableRegionGroupException;
/**
* Allocate DataPartitions
@@ -52,5 +52,5 @@ public interface IPartitionAllocator {
Map<String, DataPartitionTable> allocateDataPartition(
Map<String, Map<TSeriesPartitionSlot, List<TTimePartitionSlot>>>
unassignedDataPartitionSlotsMap)
- throws NotAvailableRegionGroupException;
+ throws NoAvailableRegionGroupException;
}
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/manager/node/NodeManager.java b/confignode/src/main/java/org/apache/iotdb/confignode/manager/node/NodeManager.java
index 86e743437b..8238594756 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/manager/node/NodeManager.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/manager/node/NodeManager.java
@@ -290,7 +290,7 @@ public class NodeManager {
if (configManager.transfer(removeDataNodePlan.getDataNodeLocations()).getCode()
!= TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
dataSet.setStatus(
- new TSStatus(TSStatusCode.NODE_DELETE_ERROR.getStatusCode())
+ new TSStatus(TSStatusCode.REMOVE_DATANODE_ERROR.getStatusCode())
.setMessage("Fail to do transfer of the DataNodes"));
return dataSet;
}
@@ -303,7 +303,7 @@ public class NodeManager {
status = new TSStatus(TSStatusCode.SUCCESS_STATUS.getStatusCode());
status.setMessage("Server accepted the request");
} else {
- status = new TSStatus(TSStatusCode.NODE_DELETE_ERROR.getStatusCode());
+ status = new TSStatus(TSStatusCode.REMOVE_DATANODE_ERROR.getStatusCode());
status.setMessage("Server rejected the request, maybe requests are too many");
}
dataSet.setStatus(status);
@@ -612,7 +612,7 @@ public class NodeManager {
return new TSStatus(TSStatusCode.REMOVE_CONFIGNODE_ERROR.getStatusCode())
.setMessage("Remove ConfigNode failed because transfer ConfigNode leader failed.");
}
- return new TSStatus(TSStatusCode.NEED_REDIRECTION.getStatusCode())
+ return new TSStatus(TSStatusCode.REDIRECTION_RECOMMEND.getStatusCode())
.setRedirectNode(newLeader.getInternalEndPoint())
.setMessage(
"The ConfigNode to be removed is leader, already transfer Leader to "
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 817091fbfe..2528fe5af5 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
@@ -59,7 +59,7 @@ import org.apache.iotdb.confignode.consensus.response.GetTimeSlotListResp;
import org.apache.iotdb.confignode.consensus.response.RegionInfoListResp;
import org.apache.iotdb.confignode.consensus.response.SchemaNodeManagementResp;
import org.apache.iotdb.confignode.consensus.response.SchemaPartitionResp;
-import org.apache.iotdb.confignode.exception.NotAvailableRegionGroupException;
+import org.apache.iotdb.confignode.exception.NoAvailableRegionGroupException;
import org.apache.iotdb.confignode.exception.NotEnoughDataNodeException;
import org.apache.iotdb.confignode.exception.StorageGroupNotExistsException;
import org.apache.iotdb.confignode.manager.ClusterSchemaManager;
@@ -217,10 +217,10 @@ public class PartitionManager {
try {
assignedSchemaPartition =
getLoadManager().allocateSchemaPartition(unassignedSchemaPartitionSlotsMap);
- } catch (NotAvailableRegionGroupException e) {
+ } catch (NoAvailableRegionGroupException e) {
LOGGER.error(e.getMessage());
resp.setStatus(
- new TSStatus(TSStatusCode.NOT_AVAILABLE_REGION_GROUP.getStatusCode())
+ new TSStatus(TSStatusCode.NO_AVAILABLE_REGION_GROUP.getStatusCode())
.setMessage(e.getMessage()));
return resp;
}
@@ -294,10 +294,10 @@ public class PartitionManager {
try {
assignedDataPartition =
getLoadManager().allocateDataPartition(unassignedDataPartitionSlotsMap);
- } catch (NotAvailableRegionGroupException e) {
+ } catch (NoAvailableRegionGroupException e) {
LOGGER.error(e.getMessage());
resp.setStatus(
- new TSStatus(TSStatusCode.NOT_AVAILABLE_REGION_GROUP.getStatusCode())
+ new TSStatus(TSStatusCode.NO_AVAILABLE_REGION_GROUP.getStatusCode())
.setMessage(e.getMessage()));
return resp;
}
@@ -501,11 +501,11 @@ public class PartitionManager {
* @param storageGroup StorageGroupName
* @param type SchemaRegion or DataRegion
* @return The specific StorageGroup's Regions that sorted by the number of allocated slots
- * @throws NotAvailableRegionGroupException When all RegionGroups within the specified
- * StorageGroup are unavailable currently
+ * @throws NoAvailableRegionGroupException When all RegionGroups within the specified StorageGroup
+ * are unavailable currently
*/
public List<Pair<Long, TConsensusGroupId>> getSortedRegionGroupSlotsCounter(
- String storageGroup, TConsensusGroupType type) throws NotAvailableRegionGroupException {
+ String storageGroup, TConsensusGroupType type) throws NoAvailableRegionGroupException {
// Collect static data
List<Pair<Long, TConsensusGroupId>> regionGroupSlotsCounter =
partitionInfo.getRegionGroupSlotsCounter(storageGroup, type);
@@ -521,7 +521,7 @@ public class PartitionManager {
}
if (result.isEmpty()) {
- throw new NotAvailableRegionGroupException();
+ throw new NoAvailableRegionGroupException();
}
result.sort(Comparator.comparingLong(Pair::getLeft));
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 8f3eb1b1f0..3941943aad 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,7 +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_ERROR, e.getMessage()));
+ result.setStatus(RpcUtils.getStatus(TSStatusCode.AUTHENTICATION_ERROR, e.getMessage()));
}
} else {
result = AuthUtils.generateEmptyPermissionInfoResp();
@@ -202,7 +202,7 @@ public class AuthorInfo implements SnapshotProcessor {
throw new AuthException("unknown type: " + authorPlan.getAuthorType());
}
} catch (AuthException e) {
- return RpcUtils.getStatus(TSStatusCode.EXECUTE_PERMISSION_ERROR, e.getMessage());
+ return RpcUtils.getStatus(TSStatusCode.AUTHENTICATION_ERROR, e.getMessage());
}
return RpcUtils.getStatus(TSStatusCode.SUCCESS_STATUS);
}
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/service/ConfigNode.java b/confignode/src/main/java/org/apache/iotdb/confignode/service/ConfigNode.java
index 363c092d77..ba92491931 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/service/ConfigNode.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/service/ConfigNode.java
@@ -260,10 +260,10 @@ public class ConfigNode implements ConfigNodeMBean {
CONF.setConfigNodeId(resp.getConfigNodeId());
configManager.initConsensusManager();
return;
- } else if (status.getCode() == TSStatusCode.NEED_REDIRECTION.getStatusCode()) {
+ } else if (status.getCode() == TSStatusCode.REDIRECTION_RECOMMEND.getStatusCode()) {
targetConfigNode = status.getRedirectNode();
LOGGER.info("ConfigNode need redirect to {}.", targetConfigNode);
- } else if (status.getCode() == TSStatusCode.ERROR_GLOBAL_CONFIG.getStatusCode()) {
+ } else if (status.getCode() == TSStatusCode.CONFIGURATION_ERROR.getStatusCode()) {
LOGGER.error(status.getMessage());
throw new StartupException("Configuration are not consistent!");
} else if (status.getCode() == TSStatusCode.CONSENSUS_NOT_INITIALIZED.getStatusCode()) {
diff --git a/consensus/src/main/java/org/apache/iotdb/consensus/multileader/MultiLeaderConsensus.java b/consensus/src/main/java/org/apache/iotdb/consensus/multileader/MultiLeaderConsensus.java
index 91d3134b55..fab6ed0057 100644
--- a/consensus/src/main/java/org/apache/iotdb/consensus/multileader/MultiLeaderConsensus.java
+++ b/consensus/src/main/java/org/apache/iotdb/consensus/multileader/MultiLeaderConsensus.java
@@ -159,7 +159,7 @@ public class MultiLeaderConsensus implements IConsensus {
TSStatus status;
if (impl.isReadOnly()) {
- status = new TSStatus(TSStatusCode.READ_ONLY_SYSTEM.getStatusCode());
+ status = new TSStatus(TSStatusCode.SYSTEM_READ_ONLY.getStatusCode());
status.setMessage("Fail to do non-query operations because system is read-only.");
} else if (!impl.isActive()) {
// TODO: (xingtanzjr) whether we need to define a new status to indicate the inactive status ?
diff --git a/consensus/src/main/java/org/apache/iotdb/consensus/multileader/client/DispatchLogHandler.java b/consensus/src/main/java/org/apache/iotdb/consensus/multileader/client/DispatchLogHandler.java
index 0c5ef42e1b..e552acafe2 100644
--- a/consensus/src/main/java/org/apache/iotdb/consensus/multileader/client/DispatchLogHandler.java
+++ b/consensus/src/main/java/org/apache/iotdb/consensus/multileader/client/DispatchLogHandler.java
@@ -79,7 +79,7 @@ public class DispatchLogHandler implements AsyncMethodCallback<TSyncLogRes> {
private boolean needRetry(int statusCode) {
return statusCode == TSStatusCode.INTERNAL_SERVER_ERROR.getStatusCode()
- || statusCode == TSStatusCode.READ_ONLY_SYSTEM.getStatusCode()
+ || statusCode == TSStatusCode.SYSTEM_READ_ONLY.getStatusCode()
|| statusCode == TSStatusCode.WRITE_PROCESS_REJECT.getStatusCode();
}
diff --git a/consensus/src/main/java/org/apache/iotdb/consensus/multileader/service/MultiLeaderRPCServiceProcessor.java b/consensus/src/main/java/org/apache/iotdb/consensus/multileader/service/MultiLeaderRPCServiceProcessor.java
index fc3bdf123b..744a1d1463 100644
--- a/consensus/src/main/java/org/apache/iotdb/consensus/multileader/service/MultiLeaderRPCServiceProcessor.java
+++ b/consensus/src/main/java/org/apache/iotdb/consensus/multileader/service/MultiLeaderRPCServiceProcessor.java
@@ -90,7 +90,7 @@ public class MultiLeaderRPCServiceProcessor implements MultiLeaderConsensusIServ
if (impl.isReadOnly()) {
String message = "fail to sync log because system is read-only.";
logger.error(message);
- TSStatus status = new TSStatus(TSStatusCode.READ_ONLY_SYSTEM.getStatusCode());
+ TSStatus status = new TSStatus(TSStatusCode.SYSTEM_READ_ONLY.getStatusCode());
status.setMessage(message);
resultHandler.onComplete(new TSyncLogRes(Collections.singletonList(status)));
return;
diff --git a/consensus/src/main/java/org/apache/iotdb/consensus/simple/SimpleConsensus.java b/consensus/src/main/java/org/apache/iotdb/consensus/simple/SimpleConsensus.java
index beb5c21dae..0a112d1bbf 100644
--- a/consensus/src/main/java/org/apache/iotdb/consensus/simple/SimpleConsensus.java
+++ b/consensus/src/main/java/org/apache/iotdb/consensus/simple/SimpleConsensus.java
@@ -118,7 +118,7 @@ class SimpleConsensus implements IConsensus {
TSStatus status;
if (impl.isReadOnly()) {
- status = new TSStatus(TSStatusCode.READ_ONLY_SYSTEM.getStatusCode());
+ status = new TSStatus(TSStatusCode.SYSTEM_READ_ONLY.getStatusCode());
status.setMessage("Fail to do non-query operations because system is read-only.");
} else {
status = impl.write(request);
diff --git a/docs/UserGuide/API/Status-Codes.md b/docs/UserGuide/API/Status-Codes.md
index dca83e8474..a3e824882c 100644
--- a/docs/UserGuide/API/Status-Codes.md
+++ b/docs/UserGuide/API/Status-Codes.md
@@ -45,29 +45,37 @@ Here is a list of Status Code and related message:
|Status Code|Status Type|Meanings|
|:--|:---|:---|
|200|SUCCESS_STATUS||
-|201|STILL_EXECUTING_STATUS||
+
|203|INCOMPATIBLE_VERSION|Incompatible version|
-|298|NODE_DELETE_ERROR|Failed while deleting node|
+|800|CONFIGURATION_ERROR|Configuration error|
+|504|START_UP_ERROR|Meet error while starting|
+|505|SHUT_DOWN_ERROR|Meet error while shutdown|
+
+
+|703|UNSUPPORTED_OPERATION|Unsupported operation|
+|400|EXECUTE_STATEMENT_ERROR|Execute statement error|
+|506|MULTIPLE_ERROR|Meet error when executing multiple statements|
+|318|ILLEGAL_PARAMETER|Parameter is illegal|
+|920|OVERLAP_WITH_EXISTING_TASK|Current task has some conflict with existing tasks|
+|500|INTERNAL_SERVER_ERROR|Internal server error|
+
+
+|707|REDIRECTION_RECOMMEND|Recommend Client redirection|
+
+
+|322|DATABASE_NOT_EXIST|Database does not exist|
+|903|DATABASE_ALREADY_EXISTS|Database already exist|
+|337|SERIES_OVERFLOW|Series number exceeds the threshold|
+|338|TIMESERIES_ALREADY_EXIST|Timeseries number exceeds the threshold|
+|344|TIMESERIES_IN_BLACK_LIST|Timeseries is being deleted|
|299|ALIAS_ALREADY_EXIST|Alias already exists|
|300|PATH_ALREADY_EXIST|Path already exists|
|303|METADATA_ERROR|Meet error when dealing with metadata|
|304|PATH_NOT_EXIST|Path does not exist|
-|305|OUT_OF_TTL|Insertion time is less than TTL time bound|
-|307|COMPACTION_ERROR|Meet error while merging|
-|308|SYSTEM_CHECK_ERROR|Meet error while system checking|
-|310|SYNC_CONNECTION_ERROR|Meet error while sync connecting|
-|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|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|
+|315|ILLEGAL_PATH|Illegal path|
+|340|CREATE_TEMPLATE_ERROR|Create schema template error|
|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|
@@ -77,31 +85,24 @@ Here is a list of Status Code and related message:
|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|Failed to create a PIPE sink|
-|335|PIPE_ERROR|PIPE error|
-|336|PIPESERVER_ERROR|PIPE server error|
-|337|SERIES_OVERFLOW|Series number exceeds the threshold|
-|340|CREATE_TEMPLATE_ERROR|Create schema template error|
-|341|SYNC_FILE_REDIRECTION_ERROR|Sync TsFile redirection 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|DataNode cannot download UDF 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|
+
+|502|SYSTEM_READ_ONLY|IoTDB system is read only|
+|313|STORAGE_ENGINE_ERROR|Storage engine related error|
+|317|STORAGE_ENGINE_NOT_READY|The storage engine is in recovery, not ready fore accepting read/write operation|
+|311|DATAREGION_PROCESS_ERROR|DataRegion related error|
+|314|TSFILE_PROCESSOR_ERROR|TsFile processor related error|
+|412|WRITE_PROCESS_ERROR|Writing data related error|
+|413|WRITE_PROCESS_REJECT|Writing data rejected error|
+|305|OUT_OF_TTL|Insertion time is less than TTL time bound|
+|307|COMPACTION_ERROR|Meet error while merging|
+|319|ALIGNED_TIMESERIES_ERROR|Meet error in aligned timeseries|
+|333|WAL_ERROR|WAL error|
+|503|DISK_SPACE_INSUFFICIENT|Disk space is insufficient|
+
|401|SQL_PARSE_ERROR|Meet error while parsing SQL|
+|416|SEMANTIC_ERROR|SQL semantic error|
|402|GENERATE_TIME_ZONE_ERROR|Meet error while generating time zone|
|403|SET_TIME_ZONE_ERROR|Meet error while setting time zone|
|405|QUERY_NOT_ALLOWED|Query statements are not allowed error|
@@ -109,58 +110,70 @@ Here is a list of Status Code and related message:
|408|LOGICAL_OPTIMIZE_ERROR|Logical optimize related error|
|409|UNSUPPORTED_FILL_TYPE|Unsupported fill type related error|
|411|QUERY_PROCESS_ERROR|Query process related error|
-|412|WRITE_PROCESS_ERROR|Writing data related error|
-|413|WRITE_PROCESS_REJECT|Writing data rejected error|
-|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|
+|423|MPP_MEMORY_NOT_ENOUGH|Not enough memory for task execution in MPP|
|501|CLOSE_OPERATION_ERROR|Meet error in close operation|
-|502|READ_ONLY_SYSTEM|Operating system is read only|
-|503|DISK_SPACE_INSUFFICIENT|Disk space is insufficient|
-|504|START_UP_ERROR|Meet error while starting up|
-|505|SHUT_DOWN_ERROR|Meet error while shutdown|
-|506|MULTIPLE_ERROR|Meet error when executing multiple statements|
|508|TSBLOCK_SERIALIZE_ERROR|TsBlock serialization error|
+|701|INTERNAL_REQUEST_TIME_OUT|MPP Operation timeout|
+|709|INTERNAL_REQUEST_RETRY_ERROR|Internal operation retry failed|
+
+|607|AUTHENTICATION_ERROR|Error in authentication|
|600|WRONG_LOGIN_PASSWORD|Username or password is wrong|
|601|NOT_LOGIN|Has not logged in|
|602|NO_PERMISSION|No permissions for this operation, please add privilege|
|603|UNINITIALIZED_AUTH_ERROR|Uninitialized authorizer|
|605|USER_NOT_EXIST|User does not exist|
|606|ROLE_NOT_EXIST|Role does not exist|
-|607|AUTHENTICATION_FAILED|Error in authentication|
|608|CLEAR_PERMISSION_CACHE_ERROR|Error when clear the permission cache|
-|701|TIME_OUT|Operation timeout|
-|703|UNSUPPORTED_OPERATION|Unsupported operation|
-|706|NO_CONNECTION|Can not get connection error|
-|707|NEED_REDIRECTION|Need direction|
-|709|ALL_RETRY_ERROR|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_ERROR|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|CONFIGURATION_ERROR|Configuration error|
+|918|REGION_LEADER_CHANGE_ERROR|Region leader migration failed|
+|921|NO_AVAILABLE_REGION_GROUP|Cannot find an available region group|
+
|901|DATANODE_ALREADY_REGISTERED|DataNode already registered in cluster|
-|903|DATABASE_ALREADY_EXISTS|Database already exist|
|904|NO_ENOUGH_DATANODE|The number of DataNode is not enough, cannot remove DataNode or create enough replication|
-|905|ERROR_GLOBAL_CONFIG|Global config in cluster does not consistent|
|906|ADD_CONFIGNODE_ERROR|Add ConfigNode error|
|907|REMOVE_CONFIGNODE_ERROR|Remove ConfigNode error|
|912|DATANODE_NOT_EXIST|DataNode not exist error|
|917|DATANODE_STOP_ERROR|DataNode stop error|
-|918|REGION_LEADER_CHANGE_ERROR|Region leader migration failed|
|919|REMOVE_DATANODE_ERROR|Remove datanode failed|
-|920|OVERLAP_WITH_EXISTING_TASK|Current task has some conflict with existing tasks|
-|921|NOT_AVAILABLE_REGION_GROUP|Cannot find an available region group|
-|922|CREATE_TRIGGER_ERROR|ConfigNode create trigger error|
-|923|DROP_TRIGGER_ERROR|ConfigNode delete Trigger error|
|925|REGISTER_REMOVED_DATANODE|The DataNode to be registered is removed before|
-|930|NO_SUCH_CQ|CQ task does not exist|
-|931|CQ_ALREADY_ACTIVE|CQ is already active|
-|932|CQ_AlREADY_EXIST|CQ is already exist|
-|933|CQ_UPDATE_LAST_EXEC_TIME_ERROR|CQ update last execution time failed|
+|706|CAN_NOT_CONNECT_DATANODE|Can not connect to DataNode|
+
+|316|LOAD_FILE_ERROR|Meet error while loading file|
+|417|LOAD_PIECE_OF_TSFILE_ERROR|Error when load a piece of TsFile when loading|
+|714|DESERIALIZE_PIECE_OF_TSFILE_ERROR|Error when deserialize a piece of TsFile|
+
+|334|CREATE_PIPE_SINK_ERROR|Failed to create a PIPE sink|
+|335|PIPE_ERROR|PIPE error|
+|336|PIPESERVER_ERROR|PIPE server error|
+|310|SYNC_CONNECTION_ERROR|Meet error while sync connecting|
+|341|SYNC_FILE_REDIRECTION_ERROR|Sync TsFile redirection error|
+|342|SYNC_FILE_ERROR|Sync TsFile error|
+|343|VERIFY_METADATA_ERROR|Meet error in validate timeseries schema|
+
+|370|UDF_LOAD_CLASS_ERROR|Error when loading UDF class|
+|371|UDF_DOWNLOAD_ERROR|DataNode cannot download UDF from ConfigNode|
+|372|CREATE_UDF_ON_DATANODE_ERROR|Error when create UDF on DataNode|
+|373|DROP_UDF_ON_DATANODE_ERROR|Error when drop a UDF on DataNode|
+
+|950|CREATE_TRIGGER_ERROR|ConfigNode create trigger error|
+|951|DROP_TRIGGER_ERROR|ConfigNode delete Trigger error|
+|952|TRIGGER_FIRE_ERROR|Error when firing trigger|
+|953|TRIGGER_LOAD_CLASS_ERROR|Error when load class of trigger|
+|954|TRIGGER_DOWNLOAD_ERROR|Error when download trigger from ConfigNode|
+|955|CREATE_TRIGGER_INSTANCE_ERROR|Error when create trigger instance|
+|956|ACTIVE_TRIGGER_INSTANCE_ERROR|Error when activate trigger instance|
+|957|DROP_TRIGGER_INSTANCE_ERROR|Error when drop trigger instance|
+|958|UPDATE_TRIGGER_LOCATION_ERROR|Error when move stateful trigger to new datanode|
+
+|1000|NO_SUCH_CQ|CQ task does not exist|
+|1001|CQ_ALREADY_ACTIVE|CQ is already active|
+|1002|CQ_AlREADY_EXIST|CQ is already exist|
+|1003|CQ_UPDATE_LAST_EXEC_TIME_ERROR|CQ update last execution time failed|
> All exceptions are refactored in the 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 95f07324dd..fcf80e4a0b 100644
--- a/docs/zh/UserGuide/API/Status-Codes.md
+++ b/docs/zh/UserGuide/API/Status-Codes.md
@@ -46,29 +46,37 @@ try {
|状态码|状态类型|状态信息|
|:--|:---|:---|
|200|SUCCESS_STATUS|成功状态|
-|201|STILL_EXECUTING_STATUS|仍在执行状态|
+
|203|INCOMPATIBLE_VERSION|版本不兼容|
-|298|NODE_DELETE_ERROR|删除节点失败|
+|800|CONFIGURATION_ERROR|配置文件有错误项|
+|504|START_UP_ERROR|启动错误|
+|505|SHUT_DOWN_ERROR|关机错误|
+
+
+|703|UNSUPPORTED_OPERATION|不支持的操作|
+|400|EXECUTE_STATEMENT_ERROR|执行语句错误|
+|506|MULTIPLE_ERROR|多行语句执行错误|
+|318|ILLEGAL_PARAMETER|参数错误|
+|920|OVERLAP_WITH_EXISTING_TASK|与正在执行的其他操作冲突|
+|500|INTERNAL_SERVER_ERROR|服务器内部错误|
+
+
+|707|REDIRECTION_RECOMMEND|推荐客户端重定向|
+
+
+|322|DATABASE_NOT_EXIST|数据库不存在|
+|903|DATABASE_ALREADY_EXISTS|数据库已存在|
+|337|SERIES_OVERFLOW|序列数量超过阈值|
+|338|TIMESERIES_ALREADY_EXIST|序列数量超过阈值|
+|344|TIMESERIES_IN_BLACK_LIST|时间序列正在删除|
|299|ALIAS_ALREADY_EXIST|路径别名已经存在|
|300|PATH_ALREADY_EXIST|路径已经存在|
|303|METADATA_ERROR|处理元数据错误|
|304|PATH_NOT_EXIST|路径不存在|
-|305|OUT_OF_TTL|插入时间少于 TTL 时间边界|
-|307|COMPACTION_ERROR|合并错误|
-|308|SYSTEM_CHECK_ERROR|系统检查错误|
-|310|SYNC_CONNECTION_ERROR|回传连接错误|
-|311|DATABASE_PROCESS_ERROR|存储组处理器相关错误|
-|313|STORAGE_ENGINE_ERROR|存储引擎相关错误|
-|314|TSFILE_PROCESSOR_ERROR|TsFile 处理器相关错误|
-|315|PATH_ILLEGAL|路径不合法|
-|316|LOAD_FILE_ERROR|加载文件错误|
-|317|DATABASE_NOT_READY|Database 还在恢复中，还不能接受读写操作|
-|318|ILLEGAL_PARAMETER|参数错误|
-|319|ALIGNED_TIMESERIES_ERROR|对齐时间序列错误|
+|315|ILLEGAL_PATH|路径不合法|
+|340|CREATE_TEMPLATE_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|元数据模板正在使用|
@@ -78,32 +86,25 @@ try {
|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 异常|
-|337|SERIES_OVERFLOW|序列数量超过阈值|
-|338|MEASUREMENT_ALREADY_EXIST|序列数量超过阈值|
-|340|CREATE_TEMPLATE_ERROR|创建物理量模板失败|
-|341|SYNC_FILE_REDIRECTION_ERROR|同步文件时重定向异常|
-|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|执行语句错误|
+
+|502|SYSTEM_READ_ONLY|IoTDB 系统只读|
+|313|STORAGE_ENGINE_ERROR|存储引擎相关错误|
+|317|STORAGE_ENGINE_NOT_READY|存储引擎还在恢复中，还不能接受读写操作|
+|311|DATAREGION_PROCESS_ERROR|DataRegion 相关错误|
+|314|TSFILE_PROCESSOR_ERROR|TsFile 处理器相关错误|
+|412|WRITE_PROCESS_ERROR|写入相关错误|
+|413|WRITE_PROCESS_REJECT|写入拒绝错误|
+|305|OUT_OF_TTL|插入时间少于 TTL 时间边界|
+|307|COMPACTION_ERROR|合并错误|
+|319|ALIGNED_TIMESERIES_ERROR|对齐时间序列错误|
+|333|WAL_ERROR|WAL 异常|
+|503|DISK_SPACE_INSUFFICIENT|磁盘空间不足|
+
+
|401|SQL_PARSE_ERROR|SQL 语句分析错误|
+|416|SEMANTIC_ERROR|SQL 语义错误|
|402|GENERATE_TIME_ZONE_ERROR|生成时区错误|
|403|SET_TIME_ZONE_ERROR|设置时区错误|
|405|QUERY_NOT_ALLOWED|查询语句不允许|
@@ -111,59 +112,70 @@ try {
|408|LOGICAL_OPTIMIZE_ERROR|逻辑优化相关错误|
|409|UNSUPPORTED_FILL_TYPE|不支持的填充类型|
|411|QUERY_PROCESS_ERROR|查询处理相关错误|
-|412|WRITE_PROCESS_ERROR|写入相关错误|
-|413|WRITE_PROCESS_REJECT|写入拒绝错误|
-|416|SEMANTIC_ERROR|SQL 语义错误|
-|417|LOAD_PIECE_OF_TSFILE_ERROR|加载 TsFile 片段异常|
-|423|MEMORY_NOT_ENOUGH|MPP 框架中任务执行内存不足|
-|500|INTERNAL_SERVER_ERROR|服务器内部错误|
+|423|MPP_MEMORY_NOT_ENOUGH|MPP 框架中任务执行内存不足|
|501|CLOSE_OPERATION_ERROR|关闭操作错误|
-|502|READ_ONLY_SYSTEM|系统只读|
-|503|DISK_SPACE_INSUFFICIENT|磁盘空间不足|
-|504|START_UP_ERROR|启动错误|
-|505|SHUT_DOWN_ERROR|关机错误|
-|506|MULTIPLE_ERROR|多行语句执行错误|
|508|TSBLOCK_SERIALIZE_ERROR|TsBlock 序列化错误|
+|701|INTERNAL_REQUEST_TIME_OUT|MPP 操作超时|
+|709|INTERNAL_REQUEST_RETRY_ERROR|内部操作重试失败|
+
+|607|AUTHENTICATION_ERROR|权限认证失败|
|600|WRONG_LOGIN_PASSWORD|用户名或密码错误|
|601|NOT_LOGIN|没有登录|
|602|NO_PERMISSION|没有操作权限|
|603|UNINITIALIZED_AUTH_ERROR|授权人未初始化|
-|604|EXECUTE_PERMISSION_EXCEPTION_ERROR||
|605|USER_NOT_EXIST|用户不存在|
|606|ROLE_NOT_EXIST|角色不存在|
-|607|AUTHENTICATION_FAILED|权限认证失败|
|608|CLEAR_PERMISSION_CACHE_ERROR|清空权限缓存失败|
-|701|TIME_OUT|操作超时|
-|703|UNSUPPORTED_OPERATION|不支持的操作|
-|706|NO_CONNECTION|连接获取失败|
-|707|NEED_REDIRECTION|需要重定向|
-|709|ALL_RETRY_ERROR|所有重试失败|
+
|710|MIGRATE_REGION_ERROR|Region 迁移失败|
|711|CREATE_REGION_ERROR|创建 region 失败|
|712|DELETE_REGION_ERROR|删除 region 失败|
|713|PARTITION_CACHE_UPDATE_ERROR|更新分区缓存失败|
-|714|DESERIALIZE_PIECE_OF_TSFILE_ERROR|反序列化 TsFile 片段异常|
|715|CONSENSUS_NOT_INITIALIZED|共识层未初始化，不能提供服务|
-|800|CONFIGURATION_ERROR|配置文件有错误项|
+|918|REGION_LEADER_CHANGE_ERROR|Region leader 迁移失败|
+|921|NO_AVAILABLE_REGION_GROUP|无法找到可用的 Region 副本组|
+
|901|DATANODE_ALREADY_REGISTERED|DataNode 在集群中已经注册|
-|903|DATABASE_ALREADY_EXISTS|Database 已存在|
|904|NO_ENOUGH_DATANODE|DataNode 数量不足，无法移除节点或创建副本|
-|905|ERROR_GLOBAL_CONFIG|全局配置参数异常|
|906|ADD_CONFIGNODE_ERROR|新增 ConfigNode 失败|
|907|REMOVE_CONFIGNODE_ERROR|移除 ConfigNode 失败|
|912|DATANODE_NOT_EXIST|此 DataNode 不存在|
|917|DATANODE_STOP_ERROR|DataNode 关闭失败|
-|918|REGION_LEADER_CHANGE_ERROR|Region leader 迁移失败|
|919|REMOVE_DATANODE_ERROR|移除 datanode 失败|
-|920|OVERLAP_WITH_EXISTING_TASK|与正在执行的其他操作冲突|
-|921|NOT_AVAILABLE_REGION_GROUP|无法找到可用的 Region 副本组|
-|922|CREATE_TRIGGER_ERROR|ConfigNode 创建 Trigger 失败|
-|923|DROP_TRIGGER_ERROR|ConfigNode 删除 Trigger 失败|
|925|REGISTER_REMOVED_DATANODE|注册的 DataNode 已经被移除|
-|930|NO_SUCH_CQ|CQ 任务不存在|
-|931|CQ_ALREADY_ACTIVE|CQ 任务已激活|
-|932|CQ_AlREADY_EXIST|CQ 任务已存在|
-|933|CQ_UPDATE_LAST_EXEC_TIME_ERROR|CQ 更新上一次执行时间失败|
+|706|CAN_NOT_CONNECT_DATANODE|连接 DataNode 失败|
+
+|316|LOAD_FILE_ERROR|加载文件错误|
+|417|LOAD_PIECE_OF_TSFILE_ERROR|加载 TsFile 片段异常|
+|714|DESERIALIZE_PIECE_OF_TSFILE_ERROR|反序列化 TsFile 片段异常|
+
+|310|SYNC_CONNECTION_ERROR|回传连接错误|
+|341|SYNC_FILE_REDIRECTION_ERROR|同步文件时重定向异常|
+|342|SYNC_FILE_ERROR|同步文件异常|
+|334|CREATE_PIPE_SINK_ERROR|创建 PIPE Sink 失败|
+|335|PIPE_ERROR|PIPE 异常|
+|336|PIPESERVER_ERROR|PIPE server 异常|
+|343|VERIFY_METADATA_ERROR|校验元数据失败|
+
+|370|UDF_LOAD_CLASS_ERROR|UDF 加载类异常|
+|371|UDF_DOWNLOAD_ERROR|无法从 ConfigNode 下载 UDF|
+|372|CREATE_UDF_ON_DATANODE_ERROR|在 DataNode 创建 UDF 失败|
+|373|DROP_UDF_ON_DATANODE_ERROR|在 DataNode 卸载 UDF 失败|
+
+|950|CREATE_TRIGGER_ERROR|ConfigNode 创建 Trigger 失败|
+|951|DROP_TRIGGER_ERROR|ConfigNode 删除 Trigger 失败|
+|952|TRIGGER_FIRE_ERROR|触发器执行错误|
+|953|TRIGGER_LOAD_CLASS_ERROR|触发器加载类异常|
+|954|TRIGGER_DOWNLOAD_ERROR|从 ConfigNode 下载触发器异常|
+|955|CREATE_TRIGGER_INSTANCE_ERROR|创建触发器实例异常|
+|956|ACTIVE_TRIGGER_INSTANCE_ERROR|激活触发器实例异常|
+|957|DROP_TRIGGER_INSTANCE_ERROR|删除触发器实例异常|
+|958|UPDATE_TRIGGER_LOCATION_ERROR|更新有状态的触发器所在 DataNode 异常|
+
+|1000|NO_SUCH_CQ|CQ 任务不存在|
+|1001|CQ_ALREADY_ACTIVE|CQ 任务已激活|
+|1002|CQ_AlREADY_EXIST|CQ 任务已存在|
+|1003|CQ_UPDATE_LAST_EXEC_TIME_ERROR|CQ 更新上一次执行时间失败|
> 在最新版本中，我们重构了 IoTDB 的异常类。通过将错误信息统一提取到异常类中，并为所有异常添加不同的错误代码，从而当捕获到异常并引发更高级别的异常时，错误代码将保留并传递，以便用户了解详细的错误原因。
除此之外，我们添加了一个基础异常类“ProcessException”，由所有异常扩展。
diff --git a/integration-test/src/test/java/org/apache/iotdb/session/it/IoTDBSessionSimpleIT.java b/integration-test/src/test/java/org/apache/iotdb/session/it/IoTDBSessionSimpleIT.java
index 7e1b8d5cae..60f85f50ae 100644
--- a/integration-test/src/test/java/org/apache/iotdb/session/it/IoTDBSessionSimpleIT.java
+++ b/integration-test/src/test/java/org/apache/iotdb/session/it/IoTDBSessionSimpleIT.java
@@ -1011,7 +1011,7 @@ public class IoTDBSessionSimpleIT {
e.getMessage()
.contains(
String.format(
- msg, TSStatusCode.PATH_ILLEGAL, OperationType.INSERT_RECORDS, deviceId)));
+ msg, TSStatusCode.ILLEGAL_PATH, OperationType.INSERT_RECORDS, deviceId)));
}
try {
@@ -1023,7 +1023,7 @@ public class IoTDBSessionSimpleIT {
.contains(
String.format(
msg,
- TSStatusCode.PATH_ILLEGAL,
+ TSStatusCode.ILLEGAL_PATH,
OperationType.INSERT_STRING_RECORDS,
deviceIds.get(0))));
}
@@ -1036,7 +1036,7 @@ public class IoTDBSessionSimpleIT {
e.getMessage()
.contains(
String.format(
- msg, TSStatusCode.PATH_ILLEGAL, OperationType.INSERT_RECORD, deviceId)));
+ msg, TSStatusCode.ILLEGAL_PATH, OperationType.INSERT_RECORD, deviceId)));
}
try {
@@ -1048,7 +1048,7 @@ public class IoTDBSessionSimpleIT {
.contains(
String.format(
msg,
- TSStatusCode.PATH_ILLEGAL,
+ TSStatusCode.ILLEGAL_PATH,
OperationType.INSERT_STRING_RECORD,
deviceId)));
}
@@ -1063,7 +1063,7 @@ public class IoTDBSessionSimpleIT {
.contains(
String.format(
msg,
- TSStatusCode.PATH_ILLEGAL,
+ TSStatusCode.ILLEGAL_PATH,
OperationType.INSERT_RECORDS_OF_ONE_DEVICE,
deviceId)));
}
@@ -1077,7 +1077,7 @@ public class IoTDBSessionSimpleIT {
.contains(
String.format(
msg,
- TSStatusCode.PATH_ILLEGAL,
+ TSStatusCode.ILLEGAL_PATH,
OperationType.DELETE_DATA,
deviceId + ".s1")));
}
@@ -1108,7 +1108,7 @@ public class IoTDBSessionSimpleIT {
e.getMessage()
.contains(
String.format(
- msg, TSStatusCode.PATH_ILLEGAL, OperationType.INSERT_TABLET, deviceId)));
+ msg, TSStatusCode.ILLEGAL_PATH, OperationType.INSERT_TABLET, deviceId)));
}
try {
@@ -1152,7 +1152,7 @@ public class IoTDBSessionSimpleIT {
e.getMessage()
.contains(
String.format(
- msg, TSStatusCode.PATH_ILLEGAL, OperationType.INSERT_TABLETS, deviceId)));
+ msg, TSStatusCode.ILLEGAL_PATH, OperationType.INSERT_TABLETS, deviceId)));
}
try {
@@ -1164,7 +1164,7 @@ public class IoTDBSessionSimpleIT {
.contains(
String.format(
msg,
- TSStatusCode.PATH_ILLEGAL,
+ TSStatusCode.ILLEGAL_PATH,
OperationType.SET_STORAGE_GROUP,
"root..sg")));
}
@@ -1179,7 +1179,7 @@ public class IoTDBSessionSimpleIT {
.contains(
String.format(
msg,
- TSStatusCode.PATH_ILLEGAL,
+ TSStatusCode.ILLEGAL_PATH,
OperationType.CREATE_TIMESERIES,
"root.sg..d1.s1")));
}
@@ -1202,7 +1202,7 @@ public class IoTDBSessionSimpleIT {
.contains(
String.format(
msg,
- TSStatusCode.PATH_ILLEGAL,
+ TSStatusCode.ILLEGAL_PATH,
OperationType.CREATE_ALIGNED_TIMESERIES,
deviceId)));
}
@@ -1224,7 +1224,7 @@ public class IoTDBSessionSimpleIT {
.contains(
String.format(
msg,
- TSStatusCode.PATH_ILLEGAL,
+ TSStatusCode.ILLEGAL_PATH,
OperationType.CREATE_MULTI_TIMESERIES,
"root.sg.d1..s1")));
}
@@ -1238,7 +1238,7 @@ public class IoTDBSessionSimpleIT {
.contains(
String.format(
msg,
- TSStatusCode.PATH_ILLEGAL,
+ TSStatusCode.ILLEGAL_PATH,
OperationType.DELETE_TIMESERIES,
"root.sg.d1..s1")));
}
diff --git a/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBStatement.java b/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBStatement.java
index b3633436ef..80dd103eb7 100644
--- a/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBStatement.java
+++ b/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBStatement.java
@@ -343,7 +343,7 @@ public class IoTDBStatement implements Statement {
if (execResp.getCode() == TSStatusCode.MULTIPLE_ERROR.getStatusCode()) {
result[i] = execResp.getSubStatus().get(i).code;
if (result[i] != TSStatusCode.SUCCESS_STATUS.getStatusCode()
- && result[i] != TSStatusCode.NEED_REDIRECTION.getStatusCode()) {
+ && result[i] != TSStatusCode.REDIRECTION_RECOMMEND.getStatusCode()) {
allSuccess = false;
message
.append(execResp.getSubStatus().get(i).message)
@@ -356,7 +356,7 @@ public class IoTDBStatement implements Statement {
allSuccess =
allSuccess
&& (execResp.getCode() == TSStatusCode.SUCCESS_STATUS.getStatusCode()
- || execResp.getCode() == TSStatusCode.NEED_REDIRECTION.getStatusCode());
+ || execResp.getCode() == TSStatusCode.REDIRECTION_RECOMMEND.getStatusCode());
result[i] = execResp.getCode();
message.setLength(0);
message.append(execResp.getMessage());
diff --git a/node-commons/src/main/java/org/apache/iotdb/commons/exception/IllegalPathException.java b/node-commons/src/main/java/org/apache/iotdb/commons/exception/IllegalPathException.java
index 70fce45364..f1c46742cc 100644
--- a/node-commons/src/main/java/org/apache/iotdb/commons/exception/IllegalPathException.java
+++ b/node-commons/src/main/java/org/apache/iotdb/commons/exception/IllegalPathException.java
@@ -26,13 +26,13 @@ public class IllegalPathException extends MetadataException {
public IllegalPathException(String path) {
super(String.format("%s is not a legal path", path));
- errorCode = TSStatusCode.PATH_ILLEGAL.getStatusCode();
+ errorCode = TSStatusCode.ILLEGAL_PATH.getStatusCode();
this.isUserException = true;
}
public IllegalPathException(String path, String reason) {
super(String.format("%s is not a legal path, because %s", path, reason));
- errorCode = TSStatusCode.PATH_ILLEGAL.getStatusCode();
+ errorCode = TSStatusCode.ILLEGAL_PATH.getStatusCode();
this.isUserException = true;
}
}
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 54d66c0ea9..6eb10e4e50 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
@@ -57,14 +57,14 @@ public class StatusUtils {
case SUCCESS_STATUS:
status.setMessage("Executed successfully.");
break;
- case TIME_OUT:
+ case INTERNAL_REQUEST_TIME_OUT:
status.setMessage("Request timed out.");
break;
case INCOMPATIBLE_VERSION:
status.setMessage("Incompatible version.");
break;
- case NODE_DELETE_ERROR:
- status.setMessage("Failed while deleting node.");
+ case REMOVE_DATANODE_ERROR:
+ status.setMessage("Failed while removing DataNode.");
break;
case ALIAS_ALREADY_EXIST:
status.setMessage("Alias already exists.");
@@ -84,13 +84,10 @@ public class StatusUtils {
case COMPACTION_ERROR:
status.setMessage("Meet error while merging.");
break;
- case SYSTEM_CHECK_ERROR:
- status.setMessage("Meet error while system checking.");
- break;
case SYNC_CONNECTION_ERROR:
status.setMessage("Meet error while sync connecting.");
break;
- case DATABASE_PROCESS_ERROR:
+ case DATAREGION_PROCESS_ERROR:
status.setMessage("Database processor related error.");
break;
case STORAGE_ENGINE_ERROR:
@@ -99,7 +96,7 @@ public class StatusUtils {
case TSFILE_PROCESSOR_ERROR:
status.setMessage("TsFile processor related error.");
break;
- case PATH_ILLEGAL:
+ case ILLEGAL_PATH:
status.setMessage("Illegal path.");
break;
case LOAD_FILE_ERROR:
@@ -141,7 +138,7 @@ public class StatusUtils {
case CLOSE_OPERATION_ERROR:
status.setMessage("Meet error in close operation.");
break;
- case READ_ONLY_SYSTEM:
+ case SYSTEM_READ_ONLY:
status.setMessage("Database is read-only.");
break;
case DISK_SPACE_INSUFFICIENT:
@@ -165,7 +162,7 @@ public class StatusUtils {
case UNSUPPORTED_OPERATION:
status.setMessage("Unsupported operation.");
break;
- case NO_CONNECTION:
+ case CAN_NOT_CONNECT_DATANODE:
status.setMessage("Node cannot be reached.");
break;
default:
diff --git a/server/src/main/java/org/apache/iotdb/db/auth/StandaloneAuthorityFetcher.java b/server/src/main/java/org/apache/iotdb/db/auth/StandaloneAuthorityFetcher.java
index 735fd42c35..12bedec871 100644
--- a/server/src/main/java/org/apache/iotdb/db/auth/StandaloneAuthorityFetcher.java
+++ b/server/src/main/java/org/apache/iotdb/db/auth/StandaloneAuthorityFetcher.java
@@ -50,7 +50,7 @@ public class StandaloneAuthorityFetcher implements IAuthorityFetcher {
return RpcUtils.getStatus(TSStatusCode.WRONG_LOGIN_PASSWORD, "Authentication failed.");
}
} catch (AuthException e) {
- return RpcUtils.getStatus(TSStatusCode.AUTHENTICATION_FAILED, e.getMessage());
+ return RpcUtils.getStatus(TSStatusCode.AUTHENTICATION_ERROR, e.getMessage());
}
}
diff --git a/server/src/main/java/org/apache/iotdb/db/client/ConfigNodeClient.java b/server/src/main/java/org/apache/iotdb/db/client/ConfigNodeClient.java
index e85ae84c85..9b699608f7 100644
--- a/server/src/main/java/org/apache/iotdb/db/client/ConfigNodeClient.java
+++ b/server/src/main/java/org/apache/iotdb/db/client/ConfigNodeClient.java
@@ -269,7 +269,7 @@ public class ConfigNodeClient
}
private boolean updateConfigNodeLeader(TSStatus status) {
- if (status.getCode() == TSStatusCode.NEED_REDIRECTION.getStatusCode()) {
+ if (status.getCode() == TSStatusCode.REDIRECTION_RECOMMEND.getStatusCode()) {
if (status.isSetRedirectNode()) {
configLeader =
new TEndPoint(status.getRedirectNode().getIp(), status.getRedirectNode().getPort());
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 edc2483679..a694f80c69 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.DATABASE_PROCESS_ERROR.getStatusCode());
+ status.setCode(TSStatusCode.LOAD_FILE_ERROR.getStatusCode());
status.setMessage(e.getMessage());
return status;
}
@@ -763,11 +763,7 @@ public class StorageEngineV2 implements IService {
status.setCode(TSStatusCode.ILLEGAL_PARAMETER.getStatusCode());
status.setMessage(String.format("Wrong load command %s.", loadCommand));
}
- } catch (IOException e) {
- logger.error(String.format("Execute load command %s error.", loadCommand), e);
- status.setCode(TSStatusCode.DATABASE_PROCESS_ERROR.getStatusCode());
- status.setMessage(e.getMessage());
- } catch (LoadFileException e) {
+ } catch (IOException | LoadFileException e) {
logger.error(String.format("Execute load command %s error.", loadCommand), e);
status.setCode(TSStatusCode.LOAD_FILE_ERROR.getStatusCode());
status.setMessage(e.getMessage());
diff --git a/server/src/main/java/org/apache/iotdb/db/exception/ContinuousQueryException.java b/server/src/main/java/org/apache/iotdb/db/exception/ContinuousQueryException.java
deleted file mode 100644
index e846e986e6..0000000000
--- a/server/src/main/java/org/apache/iotdb/db/exception/ContinuousQueryException.java
+++ /dev/null
@@ -1,36 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package org.apache.iotdb.db.exception;
-
-import org.apache.iotdb.rpc.TSStatusCode;
-
-public class ContinuousQueryException extends StorageEngineException {
-
- public ContinuousQueryException(String message) {
- super(message, TSStatusCode.CONTINUOUS_QUERY_ERROR.getStatusCode());
- this.isUserException = true;
- }
-
- public ContinuousQueryException(String message, Exception e) {
- super(message, e);
- this.errorCode = TSStatusCode.CONTINUOUS_QUERY_ERROR.getStatusCode();
- this.isUserException = true;
- }
-}
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 5c76935147..3dc9f5d710 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.DATABASE_PROCESS_ERROR.getStatusCode());
+ super(exception, TSStatusCode.DATAREGION_PROCESS_ERROR.getStatusCode());
}
public DataRegionException(String message) {
- super(message, TSStatusCode.DATABASE_PROCESS_ERROR.getStatusCode());
+ super(message, TSStatusCode.DATAREGION_PROCESS_ERROR.getStatusCode());
}
}
diff --git a/server/src/main/java/org/apache/iotdb/db/exception/StorageEngineReadonlyException.java b/server/src/main/java/org/apache/iotdb/db/exception/StorageEngineReadonlyException.java
index 184e584683..1d272280e9 100644
--- a/server/src/main/java/org/apache/iotdb/db/exception/StorageEngineReadonlyException.java
+++ b/server/src/main/java/org/apache/iotdb/db/exception/StorageEngineReadonlyException.java
@@ -27,6 +27,6 @@ public class StorageEngineReadonlyException extends StorageEngineException {
"Database is read-only, and does not accept non-query operation now";
public StorageEngineReadonlyException() {
- super(ERROR_MESSAGE, TSStatusCode.READ_ONLY_SYSTEM.getStatusCode());
+ super(ERROR_MESSAGE, TSStatusCode.SYSTEM_READ_ONLY.getStatusCode());
}
}
diff --git a/server/src/main/java/org/apache/iotdb/db/exception/SystemCheckException.java b/server/src/main/java/org/apache/iotdb/db/exception/SystemCheckException.java
deleted file mode 100644
index 609a24be8f..0000000000
--- a/server/src/main/java/org/apache/iotdb/db/exception/SystemCheckException.java
+++ /dev/null
@@ -1,34 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package org.apache.iotdb.db.exception;
-
-import org.apache.iotdb.commons.exception.IoTDBException;
-import org.apache.iotdb.rpc.TSStatusCode;
-
-public class SystemCheckException extends IoTDBException {
-
- private static final long serialVersionUID = 3845398095925149972L;
-
- public SystemCheckException(String walFolder) {
- super(
- String.format("[%s] is not a directory", walFolder),
- TSStatusCode.SYSTEM_CHECK_ERROR.getStatusCode());
- }
-}
diff --git a/server/src/main/java/org/apache/iotdb/db/exception/index/UnsupportedIndexTypeException.java b/server/src/main/java/org/apache/iotdb/db/exception/index/UnsupportedIndexTypeException.java
deleted file mode 100644
index 1bea1415c6..0000000000
--- a/server/src/main/java/org/apache/iotdb/db/exception/index/UnsupportedIndexTypeException.java
+++ /dev/null
@@ -1,32 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.iotdb.db.exception.index;
-
-import org.apache.iotdb.db.exception.query.QueryProcessException;
-import org.apache.iotdb.rpc.TSStatusCode;
-
-public class UnsupportedIndexTypeException extends QueryProcessException {
-
- private static final long serialVersionUID = -7091830159338197925L;
-
- public UnsupportedIndexTypeException(String indexType) {
- super(
- "Unsupported index type: " + indexType,
- TSStatusCode.UNSUPPORTED_INDEX_TYPE.getStatusCode());
- }
-}
diff --git a/server/src/main/java/org/apache/iotdb/db/exception/metadata/DeleteFailedException.java b/server/src/main/java/org/apache/iotdb/db/exception/metadata/DeleteFailedException.java
deleted file mode 100644
index 2bff5f9300..0000000000
--- a/server/src/main/java/org/apache/iotdb/db/exception/metadata/DeleteFailedException.java
+++ /dev/null
@@ -1,40 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.iotdb.db.exception.metadata;
-
-import org.apache.iotdb.commons.exception.MetadataException;
-import org.apache.iotdb.rpc.TSStatusCode;
-
-public class DeleteFailedException extends MetadataException {
-
- private String name;
-
- public DeleteFailedException(String name) {
- super(
- String.format("Node [%s] is being used. Deletion failed.", name),
- TSStatusCode.NODE_DELETE_ERROR.getStatusCode());
- this.name = name;
- }
-
- public String getName() {
- return name;
- }
-}
diff --git a/server/src/main/java/org/apache/iotdb/db/index/common/IndexType.java b/server/src/main/java/org/apache/iotdb/db/index/common/IndexType.java
index 177e7bd47f..359b5422b4 100644
--- a/server/src/main/java/org/apache/iotdb/db/index/common/IndexType.java
+++ b/server/src/main/java/org/apache/iotdb/db/index/common/IndexType.java
@@ -18,7 +18,6 @@
*/
package org.apache.iotdb.db.index.common;
-import org.apache.iotdb.db.exception.index.UnsupportedIndexTypeException;
import org.apache.iotdb.tsfile.exception.NotImplementedException;
public enum IndexType {
@@ -72,13 +71,8 @@ public enum IndexType {
}
}
- public static IndexType getIndexType(String indexTypeString)
- throws UnsupportedIndexTypeException {
+ public static IndexType getIndexType(String indexTypeString) {
String normalized = indexTypeString.toUpperCase();
- try {
- return IndexType.valueOf(normalized);
- } catch (IllegalArgumentException e) {
- throw new UnsupportedIndexTypeException(indexTypeString);
- }
+ return IndexType.valueOf(normalized);
}
}
diff --git a/server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaRegionMemoryImpl.java b/server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaRegionMemoryImpl.java
index 7fd1e6af2e..76bcad4d5f 100644
--- a/server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaRegionMemoryImpl.java
+++ b/server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaRegionMemoryImpl.java
@@ -30,7 +30,6 @@ import org.apache.iotdb.consensus.ConsensusFactory;
import org.apache.iotdb.db.conf.IoTDBConfig;
import org.apache.iotdb.db.conf.IoTDBDescriptor;
import org.apache.iotdb.db.engine.trigger.executor.TriggerEngine;
-import org.apache.iotdb.db.exception.metadata.DeleteFailedException;
import org.apache.iotdb.db.exception.metadata.MeasurementAlreadyExistException;
import org.apache.iotdb.db.exception.metadata.PathAlreadyExistException;
import org.apache.iotdb.db.exception.metadata.PathNotExistException;
@@ -771,7 +770,7 @@ public class SchemaRegionMemoryImpl implements ISchemaRegion {
Set<String> failedNames = new HashSet<>();
int deletedNum = 0;
for (PartialPath p : allTimeseries) {
- deleteSingleTimeseriesInternal(p, failedNames);
+ deleteSingleTimeseriesInternal(p);
deletedNum++;
}
return new Pair<>(deletedNum, failedNames);
@@ -889,15 +888,10 @@ public class SchemaRegionMemoryImpl implements ISchemaRegion {
return deleteTimeseries(pathPattern, false);
}
- private void deleteSingleTimeseriesInternal(PartialPath p, Set<String> failedNames)
- throws MetadataException, IOException {
- try {
- PartialPath emptyStorageGroup = deleteOneTimeseriesUpdateStatisticsAndDropTrigger(p);
- if (!isRecovering) {
- writeToMLog(SchemaRegionPlanFactory.getDeleteTimeSeriesPlan(Collections.singletonList(p)));
- }
- } catch (DeleteFailedException e) {
- failedNames.add(e.getName());
+ private void deleteSingleTimeseriesInternal(PartialPath p) throws MetadataException, IOException {
+ deleteOneTimeseriesUpdateStatisticsAndDropTrigger(p);
+ if (!isRecovering) {
+ writeToMLog(SchemaRegionPlanFactory.getDeleteTimeSeriesPlan(Collections.singletonList(p)));
}
}
diff --git a/server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaRegionSchemaFileImpl.java b/server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaRegionSchemaFileImpl.java
index adc3ab3033..1748d31dfa 100644
--- a/server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaRegionSchemaFileImpl.java
+++ b/server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaRegionSchemaFileImpl.java
@@ -30,7 +30,6 @@ import org.apache.iotdb.db.conf.IoTDBConfig;
import org.apache.iotdb.db.conf.IoTDBDescriptor;
import org.apache.iotdb.db.engine.trigger.executor.TriggerEngine;
import org.apache.iotdb.db.exception.metadata.AliasAlreadyExistException;
-import org.apache.iotdb.db.exception.metadata.DeleteFailedException;
import org.apache.iotdb.db.exception.metadata.PathAlreadyExistException;
import org.apache.iotdb.db.exception.metadata.PathNotExistException;
import org.apache.iotdb.db.exception.metadata.SchemaDirCreationFailureException;
@@ -850,7 +849,7 @@ public class SchemaRegionSchemaFileImpl implements ISchemaRegion {
Set<String> failedNames = new HashSet<>();
int deletedNum = 0;
for (PartialPath p : allTimeseries) {
- deleteSingleTimeseriesInternal(p, failedNames);
+ deleteSingleTimeseriesInternal(p);
deletedNum++;
}
return new Pair<>(deletedNum, failedNames);
@@ -970,15 +969,10 @@ public class SchemaRegionSchemaFileImpl implements ISchemaRegion {
return deleteTimeseries(pathPattern, false);
}
- private void deleteSingleTimeseriesInternal(PartialPath p, Set<String> failedNames)
- throws MetadataException, IOException {
- try {
- PartialPath emptyStorageGroup = deleteOneTimeseriesUpdateStatisticsAndDropTrigger(p);
- if (!isRecovering) {
- writeToMLog(SchemaRegionPlanFactory.getDeleteTimeSeriesPlan(Collections.singletonList(p)));
- }
- } catch (DeleteFailedException e) {
- failedNames.add(e.getName());
+ private void deleteSingleTimeseriesInternal(PartialPath p) throws MetadataException, IOException {
+ deleteOneTimeseriesUpdateStatisticsAndDropTrigger(p);
+ if (!isRecovering) {
+ writeToMLog(SchemaRegionPlanFactory.getDeleteTimeSeriesPlan(Collections.singletonList(p)));
}
}
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/AbstractIntoOperator.java b/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/AbstractIntoOperator.java
index 4b1b57dfa3..dbcefcafea 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/AbstractIntoOperator.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/AbstractIntoOperator.java
@@ -115,7 +115,7 @@ public abstract class AbstractIntoOperator implements ProcessOperator {
}
TSStatus executionStatus = client.insertTablets(insertMultiTabletsStatement);
if (executionStatus.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()
- && executionStatus.getCode() != TSStatusCode.NEED_REDIRECTION.getStatusCode()) {
+ && executionStatus.getCode() != TSStatusCode.REDIRECTION_RECOMMEND.getStatusCode()) {
String message =
String.format(
"Error occurred while inserting tablets in SELECT INTO: %s",
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/QueryExecution.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/QueryExecution.java
index 8c48c6a574..d7707926c6 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/QueryExecution.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/QueryExecution.java
@@ -550,10 +550,11 @@ public class QueryExecution implements IQueryExecution {
// multiple devices
if (statusCode == TSStatusCode.SUCCESS_STATUS) {
List<TSStatus> subStatus = new ArrayList<>();
- tsstatus.setCode(TSStatusCode.NEED_REDIRECTION.getStatusCode());
+ tsstatus.setCode(TSStatusCode.REDIRECTION_RECOMMEND.getStatusCode());
for (TEndPoint endPoint : redirectNodeList) {
subStatus.add(
- StatusUtils.getStatus(TSStatusCode.NEED_REDIRECTION).setRedirectNode(endPoint));
+ StatusUtils.getStatus(TSStatusCode.REDIRECTION_RECOMMEND)
+ .setRedirectNode(endPoint));
}
tsstatus.setSubStatus(subStatus);
}
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 8f3f0da402..ec40b9e9d0 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
@@ -994,13 +994,13 @@ public class ClusterConfigTaskExecutor implements IConfigTaskExecutor {
if (e.getType() == TTransportException.TIMED_OUT
|| e.getCause() instanceof SocketTimeoutException) {
// time out mainly caused by slow execution, wait until
- tsStatus = RpcUtils.getStatus(TSStatusCode.STILL_EXECUTING_STATUS);
+ tsStatus = RpcUtils.getStatus(TSStatusCode.OVERLAP_WITH_EXISTING_TASK);
} else {
throw e;
}
}
// keep waiting until task ends
- } while (TSStatusCode.STILL_EXECUTING_STATUS.getStatusCode() == tsStatus.getCode());
+ } while (TSStatusCode.OVERLAP_WITH_EXISTING_TASK.getStatusCode() == tsStatus.getCode());
if (TSStatusCode.SUCCESS_STATUS.getStatusCode() != tsStatus.getCode()) {
LOGGER.error(
@@ -1078,13 +1078,13 @@ public class ClusterConfigTaskExecutor implements IConfigTaskExecutor {
if (e.getType() == TTransportException.TIMED_OUT
|| e.getCause() instanceof SocketTimeoutException) {
// time out mainly caused by slow execution, wait until
- tsStatus = RpcUtils.getStatus(TSStatusCode.STILL_EXECUTING_STATUS);
+ tsStatus = RpcUtils.getStatus(TSStatusCode.OVERLAP_WITH_EXISTING_TASK);
} else {
throw e;
}
}
// keep waiting until task ends
- } while (TSStatusCode.STILL_EXECUTING_STATUS.getStatusCode() == tsStatus.getCode());
+ } while (TSStatusCode.OVERLAP_WITH_EXISTING_TASK.getStatusCode() == tsStatus.getCode());
if (TSStatusCode.SUCCESS_STATUS.getStatusCode() != tsStatus.getCode()) {
LOGGER.error(
@@ -1294,13 +1294,13 @@ public class ClusterConfigTaskExecutor implements IConfigTaskExecutor {
if (e.getType() == TTransportException.TIMED_OUT
|| e.getCause() instanceof SocketTimeoutException) {
// time out mainly caused by slow execution, wait until
- tsStatus = RpcUtils.getStatus(TSStatusCode.STILL_EXECUTING_STATUS);
+ tsStatus = RpcUtils.getStatus(TSStatusCode.OVERLAP_WITH_EXISTING_TASK);
} else {
throw e;
}
}
// keep waiting until task ends
- } while (TSStatusCode.STILL_EXECUTING_STATUS.getStatusCode() == tsStatus.getCode());
+ } while (TSStatusCode.OVERLAP_WITH_EXISTING_TASK.getStatusCode() == tsStatus.getCode());
if (TSStatusCode.SUCCESS_STATUS.getStatusCode() != tsStatus.getCode()) {
LOGGER.error(
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/LocalExecutionPlanner.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/LocalExecutionPlanner.java
index 2121d1547e..a08f9af268 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/LocalExecutionPlanner.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/LocalExecutionPlanner.java
@@ -130,7 +130,7 @@ public class LocalExecutionPlanner {
String.format(
"There is not enough memory to execute current fragment instance, current remaining free memory is %d, estimated memory usage for current fragment instance is %d",
freeMemoryForOperators, estimatedMemorySize),
- TSStatusCode.MEMORY_NOT_ENOUGH.getStatusCode());
+ TSStatusCode.MPP_MEMORY_NOT_ENOUGH.getStatusCode());
} else {
freeMemoryForOperators -= estimatedMemorySize;
LOGGER.debug(
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/StandaloneScheduler.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/StandaloneScheduler.java
index 698dff38cc..ebceb0e10b 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/StandaloneScheduler.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/StandaloneScheduler.java
@@ -132,7 +132,7 @@ public class StandaloneScheduler implements IScheduler {
case WRITE:
// reject non-query operations when system is read-only
if (CommonDescriptor.getInstance().getConfig().isReadOnly()) {
- TSStatus failedStatus = new TSStatus(TSStatusCode.READ_ONLY_SYSTEM.getStatusCode());
+ TSStatus failedStatus = new TSStatus(TSStatusCode.SYSTEM_READ_ONLY.getStatusCode());
failedStatus.setMessage("Fail to do non-query operations because system is read-only.");
stateMachine.transitionToFailed(failedStatus);
return;
diff --git a/server/src/main/java/org/apache/iotdb/db/protocol/rest/filter/AuthorizationFilter.java b/server/src/main/java/org/apache/iotdb/db/protocol/rest/filter/AuthorizationFilter.java
index f9c774fa2a..58cf062275 100644
--- a/server/src/main/java/org/apache/iotdb/db/protocol/rest/filter/AuthorizationFilter.java
+++ b/server/src/main/java/org/apache/iotdb/db/protocol/rest/filter/AuthorizationFilter.java
@@ -108,8 +108,8 @@ public class AuthorizationFilter implements ContainerRequestFilter {
.type(MediaType.APPLICATION_JSON)
.entity(
new ExecutionStatus()
- .code(TSStatusCode.SYSTEM_CHECK_ERROR.getStatusCode())
- .message(TSStatusCode.SYSTEM_CHECK_ERROR.name()))
+ .code(TSStatusCode.AUTHENTICATION_ERROR.getStatusCode())
+ .message(TSStatusCode.AUTHENTICATION_ERROR.name()))
.build();
containerRequestContext.abortWith(resp);
return null;
diff --git a/server/src/main/java/org/apache/iotdb/db/protocol/rest/impl/GrafanaApiServiceImpl.java b/server/src/main/java/org/apache/iotdb/db/protocol/rest/impl/GrafanaApiServiceImpl.java
index 5b8449a211..fbba149e66 100644
--- a/server/src/main/java/org/apache/iotdb/db/protocol/rest/impl/GrafanaApiServiceImpl.java
+++ b/server/src/main/java/org/apache/iotdb/db/protocol/rest/impl/GrafanaApiServiceImpl.java
@@ -125,7 +125,7 @@ public class GrafanaApiServiceImpl extends GrafanaApiService {
SCHEMA_FETCHER,
config.getQueryTimeoutThreshold());
if (result.status.code != TSStatusCode.SUCCESS_STATUS.getStatusCode()
- && result.status.code != TSStatusCode.NEED_REDIRECTION.getStatusCode()) {
+ && result.status.code != TSStatusCode.REDIRECTION_RECOMMEND.getStatusCode()) {
return Response.ok()
.entity(
new ExecutionStatus()
@@ -188,7 +188,7 @@ public class GrafanaApiServiceImpl extends GrafanaApiService {
SCHEMA_FETCHER,
config.getQueryTimeoutThreshold());
if (result.status.code != TSStatusCode.SUCCESS_STATUS.getStatusCode()
- && result.status.code != TSStatusCode.NEED_REDIRECTION.getStatusCode()) {
+ && result.status.code != TSStatusCode.REDIRECTION_RECOMMEND.getStatusCode()) {
return Response.ok()
.entity(
new ExecutionStatus()
@@ -245,7 +245,7 @@ public class GrafanaApiServiceImpl extends GrafanaApiService {
SCHEMA_FETCHER,
config.getQueryTimeoutThreshold());
if (result.status.code != TSStatusCode.SUCCESS_STATUS.getStatusCode()
- && result.status.code != TSStatusCode.NEED_REDIRECTION.getStatusCode()) {
+ && result.status.code != TSStatusCode.REDIRECTION_RECOMMEND.getStatusCode()) {
return Response.ok()
.entity(
new ExecutionStatus()
diff --git a/server/src/main/java/org/apache/iotdb/db/protocol/rest/impl/RestApiServiceImpl.java b/server/src/main/java/org/apache/iotdb/db/protocol/rest/impl/RestApiServiceImpl.java
index 65431a95af..4892e13da7 100644
--- a/server/src/main/java/org/apache/iotdb/db/protocol/rest/impl/RestApiServiceImpl.java
+++ b/server/src/main/java/org/apache/iotdb/db/protocol/rest/impl/RestApiServiceImpl.java
@@ -113,7 +113,7 @@ public class RestApiServiceImpl extends RestApiService {
return Response.ok()
.entity(
(result.status.code == TSStatusCode.SUCCESS_STATUS.getStatusCode()
- || result.status.code == TSStatusCode.NEED_REDIRECTION.getStatusCode())
+ || result.status.code == TSStatusCode.REDIRECTION_RECOMMEND.getStatusCode())
? new ExecutionStatus()
.code(TSStatusCode.SUCCESS_STATUS.getStatusCode())
.message(TSStatusCode.SUCCESS_STATUS.name())
@@ -160,7 +160,7 @@ public class RestApiServiceImpl extends RestApiService {
SCHEMA_FETCHER,
config.getQueryTimeoutThreshold());
if (result.status.code != TSStatusCode.SUCCESS_STATUS.getStatusCode()
- && result.status.code != TSStatusCode.NEED_REDIRECTION.getStatusCode()) {
+ && result.status.code != TSStatusCode.REDIRECTION_RECOMMEND.getStatusCode()) {
return Response.ok()
.entity(
new ExecutionStatus()
@@ -208,7 +208,7 @@ public class RestApiServiceImpl extends RestApiService {
return Response.ok()
.entity(
(result.status.code == TSStatusCode.SUCCESS_STATUS.getStatusCode()
- || result.status.code == TSStatusCode.NEED_REDIRECTION.getStatusCode())
+ || result.status.code == TSStatusCode.REDIRECTION_RECOMMEND.getStatusCode())
? new ExecutionStatus()
.code(TSStatusCode.SUCCESS_STATUS.getStatusCode())
.message(TSStatusCode.SUCCESS_STATUS.name())
diff --git a/server/src/main/java/org/apache/iotdb/db/query/control/SessionManager.java b/server/src/main/java/org/apache/iotdb/db/query/control/SessionManager.java
index f7cc96b676..68cc811b6e 100644
--- a/server/src/main/java/org/apache/iotdb/db/query/control/SessionManager.java
+++ b/server/src/main/java/org/apache/iotdb/db/query/control/SessionManager.java
@@ -129,7 +129,7 @@ public class SessionManager implements SessionManagerMBean {
LOGGER.error("Failed to connect to ConfigNode, because ", e);
openSessionResp
.sessionId(-1)
- .setCode(TSStatusCode.AUTHENTICATION_FAILED.getStatusCode())
+ .setCode(TSStatusCode.AUTHENTICATION_ERROR.getStatusCode())
.setMessage(e.getMessage());
}
diff --git a/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/ClientRPCServiceImpl.java b/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/ClientRPCServiceImpl.java
index 27646db877..43515a61f2 100644
--- a/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/ClientRPCServiceImpl.java
+++ b/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/ClientRPCServiceImpl.java
@@ -222,7 +222,7 @@ public class ClientRPCServiceImpl implements IClientRPCServiceWithHandler {
req.getTimeout());
if (result.status.code != TSStatusCode.SUCCESS_STATUS.getStatusCode()
- && result.status.code != TSStatusCode.NEED_REDIRECTION.getStatusCode()) {
+ && result.status.code != TSStatusCode.REDIRECTION_RECOMMEND.getStatusCode()) {
return RpcUtils.getTSExecuteStatementResp(result.status);
}
@@ -1518,7 +1518,7 @@ public class ClientRPCServiceImpl implements IClientRPCServiceWithHandler {
config.getQueryTimeoutThreshold());
if (executionResult.status.code != TSStatusCode.SUCCESS_STATUS.getStatusCode()
- && executionResult.status.code != TSStatusCode.NEED_REDIRECTION.getStatusCode()) {
+ && executionResult.status.code != TSStatusCode.REDIRECTION_RECOMMEND.getStatusCode()) {
resp.setStatus(executionResult.status);
return resp;
}
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 a3e4266ec1..58a77d76a1 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
@@ -879,7 +879,7 @@ public class DataNodeInternalRPCServiceImpl implements IDataNodeRPCService.Iface
req.getTimeout());
if (result.status.code != TSStatusCode.SUCCESS_STATUS.getStatusCode()
- && result.status.code != TSStatusCode.NEED_REDIRECTION.getStatusCode()) {
+ && result.status.code != TSStatusCode.REDIRECTION_RECOMMEND.getStatusCode()) {
return result.status;
}
@@ -1299,7 +1299,7 @@ public class DataNodeInternalRPCServiceImpl implements IDataNodeRPCService.Iface
UDFManagementService.getInstance().register(udfInformation, req.jarFile);
return new TSStatus(TSStatusCode.SUCCESS_STATUS.getStatusCode());
} catch (Exception e) {
- return new TSStatus(TSStatusCode.CREATE_FUNCTION_ON_DATANODE_ERROR.getStatusCode())
+ return new TSStatus(TSStatusCode.CREATE_UDF_ON_DATANODE_ERROR.getStatusCode())
.setMessage(e.getMessage());
}
}
@@ -1310,7 +1310,7 @@ public class DataNodeInternalRPCServiceImpl implements IDataNodeRPCService.Iface
UDFManagementService.getInstance().deregister(req.getFunctionName(), req.isNeedToDeleteJar());
return new TSStatus(TSStatusCode.SUCCESS_STATUS.getStatusCode());
} catch (Exception e) {
- return new TSStatus(TSStatusCode.DROP_FUNCTION_ON_DATANODE_ERROR.getStatusCode())
+ return new TSStatus(TSStatusCode.DROP_UDF_ON_DATANODE_ERROR.getStatusCode())
.setMessage(e.getMessage());
}
}
diff --git a/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/DataNodeRegionManager.java b/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/DataNodeRegionManager.java
index 18b56fceb5..0f892bf519 100644
--- a/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/DataNodeRegionManager.java
+++ b/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/DataNodeRegionManager.java
@@ -128,7 +128,7 @@ public class DataNodeRegionManager {
}
} catch (IllegalPathException e1) {
LOGGER.error("Create Schema Region {} failed because path is illegal.", storageGroup);
- tsStatus = new TSStatus(TSStatusCode.PATH_ILLEGAL.getStatusCode());
+ tsStatus = new TSStatus(TSStatusCode.ILLEGAL_PATH.getStatusCode());
tsStatus.setMessage("Create Schema Region failed because storageGroup path is illegal.");
} catch (MetadataException e2) {
LOGGER.error("Create Schema Region {} failed because {}", storageGroup, e2.getMessage());
diff --git a/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/TSServiceImpl.java b/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/TSServiceImpl.java
index d086f5ba57..b217450312 100644
--- a/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/TSServiceImpl.java
+++ b/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/TSServiceImpl.java
@@ -733,7 +733,7 @@ public class TSServiceImpl implements IClientRPCServiceWithHandler {
port);
TSStatus status = new TSStatus();
status.setRedirectNode(new TEndPoint(ip, port));
- status.setCode(TSStatusCode.NEED_REDIRECTION.getStatusCode());
+ status.setCode(TSStatusCode.REDIRECTION_RECOMMEND.getStatusCode());
resp.setStatus(status);
resp.setQueryId(context.getQueryId());
return resp;
diff --git a/server/src/main/java/org/apache/iotdb/db/tools/WalChecker.java b/server/src/main/java/org/apache/iotdb/db/tools/WalChecker.java
index 724bd75fbc..bc4f9247ab 100644
--- a/server/src/main/java/org/apache/iotdb/db/tools/WalChecker.java
+++ b/server/src/main/java/org/apache/iotdb/db/tools/WalChecker.java
@@ -20,9 +20,9 @@ package org.apache.iotdb.db.tools;
import org.apache.iotdb.commons.exception.IllegalPathException;
import org.apache.iotdb.commons.file.SystemFileFactory;
-import org.apache.iotdb.db.exception.SystemCheckException;
import org.apache.iotdb.db.wal.buffer.WALEntry;
import org.apache.iotdb.db.wal.buffer.WALEntryType;
+import org.apache.iotdb.db.wal.exception.WALException;
import org.apache.iotdb.db.wal.utils.WALFileUtils;
import org.slf4j.Logger;
@@ -54,13 +54,13 @@ public class WalChecker {
* check the root wal dir and find the damaged files
*
* @return a list of damaged files.
- * @throws SystemCheckException if the root wal dir does not exist.
+ * @throws WALException if the root wal dir does not exist.
*/
- public List<File> doCheck() throws SystemCheckException {
+ public List<File> doCheck() throws WALException {
File walFolderFile = SystemFileFactory.INSTANCE.getFile(walFolder);
logger.info("Checking folder: {}", walFolderFile.getAbsolutePath());
if (!walFolderFile.exists() || !walFolderFile.isDirectory()) {
- throw new SystemCheckException(walFolder);
+ throw new WALException(walFolder);
}
File[] walNodeFolders = walFolderFile.listFiles(File::isDirectory);
@@ -115,7 +115,7 @@ public class WalChecker {
}
/** @param args walRootDirectory */
- public static void main(String[] args) throws SystemCheckException {
+ public static void main(String[] args) throws WALException {
if (args.length < 1) {
logger.error("No enough args: require the walRootDirectory");
return;
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 e01a94ab79..782c990c59 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.DATABASE_NOT_READY.getStatusCode()) {
+ if (status.getCode() != TSStatusCode.STORAGE_ENGINE_NOT_READY.getStatusCode()) {
String message =
String.format(
"Status code: %s, Query Statement: %s failed", status.getCode(), operation);
@@ -108,12 +108,12 @@ public class ErrorHandlingUtils {
Throwable rootCause = getRootCause(e);
// ignore logging sg not ready exception
if (rootCause instanceof StorageGroupNotReadyException) {
- return RpcUtils.getStatus(TSStatusCode.DATABASE_NOT_READY, rootCause.getMessage());
+ return RpcUtils.getStatus(TSStatusCode.STORAGE_ENGINE_NOT_READY, rootCause.getMessage());
}
Throwable t = e instanceof ExecutionException ? e.getCause() : e;
if (t instanceof QueryTimeoutRuntimeException) {
- return RpcUtils.getStatus(TSStatusCode.TIME_OUT, rootCause.getMessage());
+ return RpcUtils.getStatus(TSStatusCode.INTERNAL_REQUEST_TIME_OUT, rootCause.getMessage());
} else if (t instanceof ParseCancellationException) {
return RpcUtils.getStatus(
TSStatusCode.SQL_PARSE_ERROR, INFO_PARSING_SQL_ERROR + rootCause.getMessage());
@@ -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.DATABASE_NOT_READY.getStatusCode()) {
+ if (status.getCode() == TSStatusCode.STORAGE_ENGINE_NOT_READY.getStatusCode()) {
return RpcUtils.getStatus(Arrays.asList(batchException.getFailingStatus()));
}
}
diff --git a/server/src/main/java/org/apache/iotdb/db/wal/exception/WALException.java b/server/src/main/java/org/apache/iotdb/db/wal/exception/WALException.java
index 8f2ccebf21..ac0c666875 100644
--- a/server/src/main/java/org/apache/iotdb/db/wal/exception/WALException.java
+++ b/server/src/main/java/org/apache/iotdb/db/wal/exception/WALException.java
@@ -23,16 +23,16 @@ import org.apache.iotdb.rpc.TSStatusCode;
public class WALException extends IoTDBException {
public WALException(Throwable cause) {
- super(cause, TSStatusCode.WRITE_AHEAD_LOG_ERROR.getStatusCode());
+ super(cause, TSStatusCode.WAL_ERROR.getStatusCode());
this.initCause(cause);
}
public WALException(String msg) {
- super(msg, TSStatusCode.WRITE_AHEAD_LOG_ERROR.getStatusCode());
+ super(msg, TSStatusCode.WAL_ERROR.getStatusCode());
}
public WALException(String message, Throwable cause) {
- super(message + cause.getMessage(), TSStatusCode.WRITE_AHEAD_LOG_ERROR.getStatusCode());
+ super(message + cause.getMessage(), TSStatusCode.WAL_ERROR.getStatusCode());
this.initCause(cause);
}
}
diff --git a/server/src/test/java/org/apache/iotdb/db/tools/WalCheckerTest.java b/server/src/test/java/org/apache/iotdb/db/tools/WalCheckerTest.java
index 2019dbe99b..6ada22b36c 100644
--- a/server/src/test/java/org/apache/iotdb/db/tools/WalCheckerTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/tools/WalCheckerTest.java
@@ -21,9 +21,9 @@ package org.apache.iotdb.db.tools;
import org.apache.iotdb.commons.exception.IllegalPathException;
import org.apache.iotdb.db.constant.TestConstant;
-import org.apache.iotdb.db.exception.SystemCheckException;
import org.apache.iotdb.db.wal.buffer.WALEntry;
import org.apache.iotdb.db.wal.buffer.WALInfoEntry;
+import org.apache.iotdb.db.wal.exception.WALException;
import org.apache.iotdb.db.wal.io.ILogWriter;
import org.apache.iotdb.db.wal.io.WALFileTest;
import org.apache.iotdb.db.wal.io.WALWriter;
@@ -53,14 +53,14 @@ public class WalCheckerTest {
boolean caught = false;
try {
checker.doCheck();
- } catch (SystemCheckException e) {
+ } catch (WALException e) {
caught = true;
}
assertTrue(caught);
}
@Test
- public void testEmpty() throws IOException, SystemCheckException {
+ public void testEmpty() throws IOException, WALException {
File tempRoot = new File(TestConstant.BASE_OUTPUT_PATH.concat("root"));
tempRoot.mkdir();
@@ -73,7 +73,7 @@ public class WalCheckerTest {
}
@Test
- public void testNormalCheck() throws IOException, SystemCheckException, IllegalPathException {
+ public void testNormalCheck() throws IOException, WALException, IllegalPathException {
File tempRoot = new File(TestConstant.BASE_OUTPUT_PATH.concat("wal"));
tempRoot.mkdir();
@@ -112,7 +112,7 @@ public class WalCheckerTest {
}
@Test
- public void testAbnormalCheck() throws IOException, SystemCheckException, IllegalPathException {
+ public void testAbnormalCheck() throws IOException, WALException, IllegalPathException {
File tempRoot = new File(TestConstant.BASE_OUTPUT_PATH.concat("wal"));
tempRoot.mkdir();
@@ -156,7 +156,7 @@ public class WalCheckerTest {
}
@Test
- public void testOneDamagedCheck() throws IOException, SystemCheckException {
+ public void testOneDamagedCheck() throws IOException, WALException {
File tempRoot = new File(TestConstant.BASE_OUTPUT_PATH.concat("wal"));
tempRoot.mkdir();
diff --git a/service-rpc/src/main/java/org/apache/iotdb/rpc/RpcUtils.java b/service-rpc/src/main/java/org/apache/iotdb/rpc/RpcUtils.java
index 89c9a21c4a..1c2d64e092 100644
--- a/service-rpc/src/main/java/org/apache/iotdb/rpc/RpcUtils.java
+++ b/service-rpc/src/main/java/org/apache/iotdb/rpc/RpcUtils.java
@@ -89,7 +89,7 @@ public class RpcUtils {
verifySuccess(status.getSubStatus());
return;
}
- if (status.getCode() == TSStatusCode.NEED_REDIRECTION.getStatusCode()) {
+ if (status.getCode() == TSStatusCode.REDIRECTION_RECOMMEND.getStatusCode()) {
return;
}
if (status.code != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
@@ -103,7 +103,7 @@ public class RpcUtils {
* @param status -status
*/
public static void verifySuccess(InfluxTSStatus status) throws StatementExecutionException {
- if (status.getCode() == TSStatusCode.NEED_REDIRECTION.getStatusCode()) {
+ if (status.getCode() == TSStatusCode.REDIRECTION_RECOMMEND.getStatusCode()) {
return;
}
if (status.code != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
@@ -123,7 +123,7 @@ public class RpcUtils {
TSStatus status, List<String> devices) throws StatementExecutionException, RedirectException {
verifySuccess(status);
if (status.getCode() == TSStatusCode.MULTIPLE_ERROR.getStatusCode()
- || status.getCode() == TSStatusCode.NEED_REDIRECTION.getStatusCode()) {
+ || status.getCode() == TSStatusCode.REDIRECTION_RECOMMEND.getStatusCode()) {
Map<String, TEndPoint> deviceEndPointMap = new HashMap<>();
List<TSStatus> statusSubStatus = status.getSubStatus();
for (int i = 0; i < statusSubStatus.size(); i++) {
@@ -141,7 +141,7 @@ public class RpcUtils {
new StringBuilder().append(TSStatusCode.MULTIPLE_ERROR.getStatusCode()).append(": ");
for (TSStatus status : statuses) {
if (status.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()
- && status.getCode() != TSStatusCode.NEED_REDIRECTION.getStatusCode()) {
+ && status.getCode() != TSStatusCode.REDIRECTION_RECOMMEND.getStatusCode()) {
errMsgs.append(status.getMessage()).append("; ");
}
}
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 5bb34bc0f0..22a7debc50 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,139 +31,144 @@ import java.util.Map;
*/
public enum TSStatusCode {
SUCCESS_STATUS(200),
- STILL_EXECUTING_STATUS(201),
- INCOMPATIBLE_VERSION(203),
-
- NODE_DELETE_ERROR(298),
- ALIAS_ALREADY_EXIST(299),
- PATH_ALREADY_EXIST(300),
- METADATA_ERROR(303),
- PATH_NOT_EXIST(304),
- OUT_OF_TTL(305),
- COMPACTION_ERROR(307),
- SYSTEM_CHECK_ERROR(308),
- SYNC_CONNECTION_ERROR(310),
- DATABASE_PROCESS_ERROR(311),
- STORAGE_ENGINE_ERROR(313),
- TSFILE_PROCESSOR_ERROR(314),
- PATH_ILLEGAL(315),
- LOAD_FILE_ERROR(316),
- DATABASE_NOT_READY(317),
- ILLEGAL_PARAMETER(318),
- ALIGNED_TIMESERIES_ERROR(319),
- DUPLICATED_TEMPLATE(320),
- UNDEFINED_TEMPLATE(321),
- DATABASE_NOT_EXIST(322),
- CONTINUOUS_QUERY_ERROR(323),
- NO_TEMPLATE_ON_MNODE(324),
- DIFFERENT_TEMPLATE(325),
- TEMPLATE_IS_IN_USE(326),
- 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),
- CREATE_PIPE_SINK_ERROR(334),
- PIPE_ERROR(335),
- PIPESERVER_ERROR(336),
- SERIES_OVERFLOW(337),
- TIMESERIES_ALREADY_EXIST(338),
- CREATE_TEMPLATE_ERROR(340),
- SYNC_FILE_REDIRECTION_ERROR(341),
- SYNC_FILE_ERROR(342),
- VERIFY_METADATA_ERROR(343),
- TIMESERIES_IN_BLACK_LIST(344),
- OVERSIZE_RECORD(349),
- SCHEMA_FILE_REDO_LOG_BROKEN(350),
- TRIGGER_FIRE_ERROR(355),
- TRIGGER_LOAD_CLASS_ERROR(360),
- TRIGGER_DOWNLOAD_ERROR(361),
- CREATE_TRIGGER_INSTANCE_ERROR(362),
- ACTIVE_TRIGGER_INSTANCE_ERROR(363),
- DROP_TRIGGER_INSTANCE_ERROR(364),
- UPDATE_TRIGGER_LOCATION_ERROR(365),
-
- UDF_LOAD_CLASS_ERROR(370),
- UDF_DOWNLOAD_ERROR(371),
- CREATE_FUNCTION_ON_DATANODE_ERROR(372),
- DROP_FUNCTION_ON_DATANODE_ERROR(373),
-
- EXECUTE_STATEMENT_ERROR(400),
- SQL_PARSE_ERROR(401),
- GENERATE_TIME_ZONE_ERROR(402),
- SET_TIME_ZONE_ERROR(403),
- QUERY_NOT_ALLOWED(405),
- LOGICAL_OPERATOR_ERROR(407),
- LOGICAL_OPTIMIZE_ERROR(408),
- UNSUPPORTED_FILL_TYPE(409),
- QUERY_PROCESS_ERROR(411),
- WRITE_PROCESS_ERROR(412),
- WRITE_PROCESS_REJECT(413),
- SEMANTIC_ERROR(416),
- LOAD_PIECE_OF_TSFILE_ERROR(417),
-
- UNSUPPORTED_INDEX_TYPE(422),
-
- MEMORY_NOT_ENOUGH(423),
-
- INTERNAL_SERVER_ERROR(500),
- CLOSE_OPERATION_ERROR(501),
- READ_ONLY_SYSTEM(502),
- DISK_SPACE_INSUFFICIENT(503),
- START_UP_ERROR(504),
- SHUT_DOWN_ERROR(505),
- MULTIPLE_ERROR(506),
- TSBLOCK_SERIALIZE_ERROR(508),
-
- WRONG_LOGIN_PASSWORD(600),
- NOT_LOGIN(601),
- NO_PERMISSION(602),
- UNINITIALIZED_AUTH_ERROR(603),
- EXECUTE_PERMISSION_ERROR(604),
- USER_NOT_EXIST(605),
- ROLE_NOT_EXIST(606),
- AUTHENTICATION_FAILED(607),
- CLEAR_PERMISSION_CACHE_ERROR(608),
-
- // cluster-related errors
- TIME_OUT(701),
- UNSUPPORTED_OPERATION(703),
- NO_CONNECTION(706),
- NEED_REDIRECTION(707),
- ALL_RETRY_ERROR(709),
- MIGRATE_REGION_ERROR(710),
- CREATE_REGION_ERROR(711),
- DELETE_REGION_ERROR(712),
- PARTITION_CACHE_UPDATE_ERROR(713),
- DESERIALIZE_PIECE_OF_TSFILE_ERROR(714),
- CONSENSUS_NOT_INITIALIZED(715),
-
- // configuration
- CONFIGURATION_ERROR(800),
-
- // ConfigNode response
- DATANODE_ALREADY_REGISTERED(901),
- DATABASE_ALREADY_EXISTS(903),
- NO_ENOUGH_DATANODE(904),
- ERROR_GLOBAL_CONFIG(905),
- ADD_CONFIGNODE_ERROR(906),
- REMOVE_CONFIGNODE_ERROR(907),
- DATANODE_NOT_EXIST(912),
- DATANODE_STOP_ERROR(917),
- REGION_LEADER_CHANGE_ERROR(918),
- REMOVE_DATANODE_ERROR(919),
- OVERLAP_WITH_EXISTING_TASK(920),
- NOT_AVAILABLE_REGION_GROUP(921),
- CREATE_TRIGGER_ERROR(922),
- DROP_TRIGGER_ERROR(923),
- REGISTER_REMOVED_DATANODE(925),
-
- NO_SUCH_CQ(930),
- CQ_ALREADY_ACTIVE(931),
- CQ_AlREADY_EXIST(932),
- CQ_UPDATE_LAST_EXEC_TIME_ERROR(933);
+
+ // System level
+ INCOMPATIBLE_VERSION(201),
+ CONFIGURATION_ERROR(202),
+ START_UP_ERROR(203),
+ SHUT_DOWN_ERROR(204),
+
+ // General Error
+ UNSUPPORTED_OPERATION(300),
+ EXECUTE_STATEMENT_ERROR(301),
+ MULTIPLE_ERROR(302),
+ ILLEGAL_PARAMETER(303),
+ OVERLAP_WITH_EXISTING_TASK(304),
+ INTERNAL_SERVER_ERROR(305),
+
+ // Client,
+ REDIRECTION_RECOMMEND(400),
+
+ // Schema Engine
+ DATABASE_NOT_EXIST(500),
+ DATABASE_ALREADY_EXISTS(501),
+ SERIES_OVERFLOW(502),
+ TIMESERIES_ALREADY_EXIST(503),
+ TIMESERIES_IN_BLACK_LIST(504),
+ ALIAS_ALREADY_EXIST(505),
+ PATH_ALREADY_EXIST(506),
+ METADATA_ERROR(507),
+ PATH_NOT_EXIST(508),
+ ILLEGAL_PATH(509),
+ CREATE_TEMPLATE_ERROR(510),
+ DUPLICATED_TEMPLATE(511),
+ UNDEFINED_TEMPLATE(512),
+ NO_TEMPLATE_ON_MNODE(513),
+ DIFFERENT_TEMPLATE(514),
+ TEMPLATE_IS_IN_USE(515),
+ TEMPLATE_INCOMPATIBLE(516),
+ SEGMENT_NOT_FOUND(517),
+ PAGE_OUT_OF_SPACE(518),
+ RECORD_DUPLICATED(519),
+ SEGMENT_OUT_OF_SPACE(520),
+ SCHEMA_FILE_NOT_EXISTS(521),
+ OVERSIZE_RECORD(522),
+ SCHEMA_FILE_REDO_LOG_BROKEN(523),
+
+ // Storage Engine
+ SYSTEM_READ_ONLY(600),
+ STORAGE_ENGINE_ERROR(601),
+ STORAGE_ENGINE_NOT_READY(602),
+ DATAREGION_PROCESS_ERROR(603),
+ TSFILE_PROCESSOR_ERROR(604),
+ WRITE_PROCESS_ERROR(605),
+ WRITE_PROCESS_REJECT(606),
+ OUT_OF_TTL(607),
+ COMPACTION_ERROR(608),
+ ALIGNED_TIMESERIES_ERROR(609),
+ WAL_ERROR(610),
+ DISK_SPACE_INSUFFICIENT(611),
+
+ // Query Engine
+ SQL_PARSE_ERROR(700),
+ SEMANTIC_ERROR(701),
+ GENERATE_TIME_ZONE_ERROR(702),
+ SET_TIME_ZONE_ERROR(703),
+ QUERY_NOT_ALLOWED(704),
+ LOGICAL_OPERATOR_ERROR(705),
+ LOGICAL_OPTIMIZE_ERROR(706),
+ UNSUPPORTED_FILL_TYPE(707),
+ QUERY_PROCESS_ERROR(708),
+ MPP_MEMORY_NOT_ENOUGH(709),
+ CLOSE_OPERATION_ERROR(710),
+ TSBLOCK_SERIALIZE_ERROR(711),
+ INTERNAL_REQUEST_TIME_OUT(712),
+ INTERNAL_REQUEST_RETRY_ERROR(713),
+
+ // Authentication
+ AUTHENTICATION_ERROR(800),
+ WRONG_LOGIN_PASSWORD(801),
+ NOT_LOGIN(802),
+ NO_PERMISSION(803),
+ UNINITIALIZED_AUTH_ERROR(804),
+ USER_NOT_EXIST(805),
+ ROLE_NOT_EXIST(806),
+ CLEAR_PERMISSION_CACHE_ERROR(807),
+
+ // Partition Error
+ MIGRATE_REGION_ERROR(900),
+ CREATE_REGION_ERROR(901),
+ DELETE_REGION_ERROR(902),
+ PARTITION_CACHE_UPDATE_ERROR(903),
+ CONSENSUS_NOT_INITIALIZED(904),
+ REGION_LEADER_CHANGE_ERROR(905),
+ NO_AVAILABLE_REGION_GROUP(906),
+
+ // Cluster Manager
+ ADD_CONFIGNODE_ERROR(1000),
+ REMOVE_CONFIGNODE_ERROR(1001),
+ DATANODE_ALREADY_REGISTERED(1002),
+ NO_ENOUGH_DATANODE(1003),
+ DATANODE_NOT_EXIST(1004),
+ DATANODE_STOP_ERROR(1005),
+ REMOVE_DATANODE_ERROR(1006),
+ REGISTER_REMOVED_DATANODE(1007),
+ CAN_NOT_CONNECT_DATANODE(1008),
+
+ // Sync, Load TsFile
+ LOAD_FILE_ERROR(1100),
+ LOAD_PIECE_OF_TSFILE_ERROR(1101),
+ DESERIALIZE_PIECE_OF_TSFILE_ERROR(1102),
+ SYNC_CONNECTION_ERROR(1103),
+ SYNC_FILE_REDIRECTION_ERROR(1104),
+ SYNC_FILE_ERROR(1105),
+ CREATE_PIPE_SINK_ERROR(1106),
+ PIPE_ERROR(1107),
+ PIPESERVER_ERROR(1108),
+ VERIFY_METADATA_ERROR(1109),
+
+ // UDF
+ UDF_LOAD_CLASS_ERROR(1200),
+ UDF_DOWNLOAD_ERROR(1201),
+ CREATE_UDF_ON_DATANODE_ERROR(1202),
+ DROP_UDF_ON_DATANODE_ERROR(1203),
+
+ // Trigger
+ CREATE_TRIGGER_ERROR(1300),
+ DROP_TRIGGER_ERROR(1301),
+ TRIGGER_FIRE_ERROR(1302),
+ TRIGGER_LOAD_CLASS_ERROR(1303),
+ TRIGGER_DOWNLOAD_ERROR(1304),
+ CREATE_TRIGGER_INSTANCE_ERROR(1305),
+ ACTIVE_TRIGGER_INSTANCE_ERROR(1306),
+ DROP_TRIGGER_INSTANCE_ERROR(1307),
+ UPDATE_TRIGGER_LOCATION_ERROR(1308),
+
+ // Continuous Query
+ NO_SUCH_CQ(1400),
+ CQ_ALREADY_ACTIVE(1401),
+ CQ_AlREADY_EXIST(1402),
+ CQ_UPDATE_LAST_EXEC_TIME_ERROR(1403);
private final int statusCode;