This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a commit to branch consensus_module_refactor
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/consensus_module_refactor by
this push:
new 90b5a672cee enhance some error message
90b5a672cee is described below
commit 90b5a672ceea65eabfef8ceb6c4190d1afde88dc
Author: OneSizeFitQuorum <[email protected]>
AuthorDate: Mon Aug 21 16:41:57 2023 +0800
enhance some error message
Signed-off-by: OneSizeFitQuorum <[email protected]>
---
.../iotdb/confignode/manager/ClusterQuotaManager.java | 12 ++++++++++--
.../apache/iotdb/confignode/manager/ConfigManager.java | 3 +--
.../org/apache/iotdb/confignode/manager/ModelManager.java | 15 +++++++++++----
.../iotdb/confignode/manager/PermissionManager.java | 4 ++--
.../apache/iotdb/confignode/manager/TriggerManager.java | 6 +++---
.../org/apache/iotdb/confignode/manager/UDFManager.java | 2 +-
.../org/apache/iotdb/confignode/manager/cq/CQManager.java | 2 +-
.../iotdb/confignode/manager/cq/CQScheduleTask.java | 2 +-
.../apache/iotdb/confignode/manager/node/NodeManager.java | 4 ++--
.../confignode/manager/partition/PartitionManager.java | 4 ++--
.../manager/pipe/plugin/PipePluginCoordinator.java | 2 +-
.../confignode/manager/pipe/task/PipeTaskCoordinator.java | 2 +-
.../confignode/manager/schema/ClusterSchemaManager.java | 4 ++--
.../confignode/procedure/env/ConfigNodeProcedureEnv.java | 4 ++--
.../confignode/procedure/env/DataNodeRemoveHandler.java | 2 +-
.../confignode/procedure/impl/cq/CreateCQProcedure.java | 2 +-
.../procedure/impl/model/CreateModelProcedure.java | 2 +-
.../impl/pipe/plugin/CreatePipePluginProcedure.java | 4 ++--
.../impl/pipe/plugin/DropPipePluginProcedure.java | 4 ++--
.../pipe/runtime/PipeHandleLeaderChangeProcedure.java | 2 +-
.../impl/pipe/runtime/PipeHandleMetaChangeProcedure.java | 2 +-
.../procedure/impl/pipe/task/CreatePipeProcedureV2.java | 4 ++--
.../procedure/impl/pipe/task/DropPipeProcedureV2.java | 2 +-
.../procedure/impl/pipe/task/StartPipeProcedureV2.java | 4 ++--
.../procedure/impl/pipe/task/StopPipeProcedureV2.java | 4 ++--
.../procedure/impl/schema/SetTemplateProcedure.java | 6 +++---
.../impl/statemachine/CreateRegionGroupsProcedure.java | 2 +-
.../procedure/impl/trigger/CreateTriggerProcedure.java | 2 +-
.../confignode/procedure/store/ConfigProcedureStore.java | 4 ++--
.../execution/executor/RegionWriteExecutor.java | 4 ++--
30 files changed, 65 insertions(+), 51 deletions(-)
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ClusterQuotaManager.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ClusterQuotaManager.java
index 01ee76691bf..0c00005fc1b 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ClusterQuotaManager.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ClusterQuotaManager.java
@@ -94,7 +94,11 @@ public class ClusterQuotaManager {
}
return response;
} catch (ConsensusException e) {
- LOGGER.warn("Something wrong happened while calling consensus layer's
write API.", e);
+ LOGGER.warn(
+ String.format(
+ "Unexpected error happened while setting space quota on
database: %s ",
+ req.getDatabase()),
+ e);
// consensus layer related errors
TSStatus res = new
TSStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR.getStatusCode());
res.setMessage(e.getMessage());
@@ -196,7 +200,11 @@ public class ClusterQuotaManager {
}
return response;
} catch (ConsensusException e) {
- LOGGER.warn("Something wrong happened while calling consensus layer's
write API.", e);
+ LOGGER.warn(
+ String.format(
+ "Unexpected error happened while setting throttle quota on user:
%s ",
+ req.getUserName()),
+ e);
// consensus layer related errors
TSStatus res = new
TSStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR.getStatusCode());
res.setMessage(e.getMessage());
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java
index 0b586bff9a0..51688fb6b7d 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java
@@ -1137,8 +1137,7 @@ public class ConfigManager implements IManager {
Thread.currentThread().interrupt();
LOGGER.warn("Unexpected interruption during retry creating peer for
consensus group");
} catch (ConsensusException e) {
- LOGGER.error(
- "Something wrong happened while calling consensus layer's
createLocalPeer API.", e);
+ LOGGER.error("Failed to create peer for consensus group", e);
break;
}
}
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ModelManager.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ModelManager.java
index 97b2e8cf845..136d3849a88 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ModelManager.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ModelManager.java
@@ -82,7 +82,9 @@ public class ModelManager {
try {
return configManager.getConsensusManager().write(new
UpdateModelInfoPlan(req));
} catch (ConsensusException e) {
- LOGGER.warn("Something wrong happened while calling consensus layer's
write API.", e);
+ LOGGER.warn(
+ String.format("Unexpected error happened while updating model %s: ",
req.getModelId()),
+ e);
// consensus layer related errors
TSStatus res = new
TSStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR.getStatusCode());
res.setMessage(e.getMessage());
@@ -94,7 +96,10 @@ public class ModelManager {
try {
return configManager.getConsensusManager().write(new
UpdateModelStatePlan(req));
} catch (ConsensusException e) {
- LOGGER.warn("Something wrong happened while calling consensus layer's
write API.", e);
+ LOGGER.warn(
+ String.format(
+ "Unexpected error happened while updating state of model %s: ",
req.getModelId()),
+ e);
// consensus layer related errors
TSStatus res = new
TSStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR.getStatusCode());
res.setMessage(e.getMessage());
@@ -107,7 +112,8 @@ public class ModelManager {
DataSet response = configManager.getConsensusManager().read(new
ShowModelPlan(req));
return ((ModelTableResp) response).convertToThriftResponse();
} catch (ConsensusException e) {
- LOGGER.warn("Something wrong happened while calling consensus layer's
read API.", e);
+ LOGGER.warn(
+ String.format("Unexpected error happened while showing model %s: ",
req.getModelId()), e);
// consensus layer related errors
TSStatus res = new
TSStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR.getStatusCode());
res.setMessage(e.getMessage());
@@ -126,7 +132,8 @@ public class ModelManager {
DataSet response = configManager.getConsensusManager().read(new
ShowTrailPlan(req));
return ((TrailTableResp) response).convertToThriftResponse();
} catch (ConsensusException e) {
- LOGGER.warn("Something wrong happened while calling consensus layer's
read API.", e);
+ LOGGER.warn(
+ String.format("Unexpected error happened while showing trail %s: ",
req.getModelId()), e);
// consensus layer related errors
TSStatus res = new
TSStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR.getStatusCode());
res.setMessage(e.getMessage());
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/PermissionManager.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/PermissionManager.java
index e7213f9a7ca..4cb3d420fc6 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/PermissionManager.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/PermissionManager.java
@@ -74,7 +74,7 @@ public class PermissionManager {
}
return tsStatus;
} catch (ConsensusException e) {
- LOGGER.warn("Something wrong happened while calling consensus layer's
write API.", e);
+ LOGGER.warn("Failed in the write API executing the consensus layer due
to: .", e);
TSStatus res = new
TSStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR.getStatusCode());
res.setMessage(e.getMessage());
return res;
@@ -91,7 +91,7 @@ public class PermissionManager {
try {
return (PermissionInfoResp) getConsensusManager().read(authorPlan);
} catch (ConsensusException e) {
- LOGGER.warn("Something wrong happened while calling consensus layer's
read API.", e);
+ LOGGER.warn("Failed in the read API executing the consensus layer due
to: ", e);
TSStatus res = new
TSStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR.getStatusCode());
res.setMessage(e.getMessage());
PermissionInfoResp response = new PermissionInfoResp();
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/TriggerManager.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/TriggerManager.java
index 49ed4256346..c245029eff7 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/TriggerManager.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/TriggerManager.java
@@ -152,7 +152,7 @@ public class TriggerManager {
configManager.getConsensusManager().read(new
GetTriggerLocationPlan(triggerName)))
.convertToThriftResponse();
} catch (ConsensusException e) {
- LOGGER.warn("Something wrong happened while calling consensus layer's
read API.", e);
+ LOGGER.warn("Failed in the read API executing the consensus layer due
to: ", e);
return new TGetLocationForTriggerResp(
new TSStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR.getStatusCode())
.setMessage(e.getMessage()));
@@ -165,7 +165,7 @@ public class TriggerManager {
configManager.getConsensusManager().read(new
GetTriggerJarPlan(req.getJarNameList())))
.convertToThriftResponse();
} catch (ConsensusException e) {
- LOGGER.warn("Something wrong happened while calling consensus layer's
read API.", e);
+ LOGGER.warn("Failed in the read API executing the consensus layer due
to: ", e);
TSStatus res = new
TSStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR.getStatusCode());
res.setMessage(e.getMessage());
return new JarResp(res,
Collections.emptyList()).convertToThriftResponse();
@@ -223,7 +223,7 @@ public class TriggerManager {
}
}
} catch (ConsensusException e) {
- LOGGER.warn("Something wrong happened while calling consensus layer's
write API.", e);
+ LOGGER.warn("Failed in the write API executing the consensus layer due
to: .", e);
TSStatus res = new
TSStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR.getStatusCode());
res.setMessage(e.getMessage());
return res;
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/UDFManager.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/UDFManager.java
index 877c6c8bca2..5e34a24311d 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/UDFManager.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/UDFManager.java
@@ -186,7 +186,7 @@ public class UDFManager {
configManager.getConsensusManager().read(new
GetUDFJarPlan(req.getJarNameList())))
.convertToThriftResponse();
} catch (ConsensusException e) {
- LOGGER.warn("Something wrong happened while calling consensus layer's
read API.", e);
+ LOGGER.warn("Failed in the read API executing the consensus layer due
to: ", e);
TSStatus res = new
TSStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR.getStatusCode());
res.setMessage(e.getMessage());
return new JarResp(res,
Collections.emptyList()).convertToThriftResponse();
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/cq/CQManager.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/cq/CQManager.java
index 63b5db0624a..38dc8e84379 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/cq/CQManager.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/cq/CQManager.java
@@ -81,7 +81,7 @@ public class CQManager {
try {
return configManager.getConsensusManager().write(new
DropCQPlan(req.cqId));
} catch (ConsensusException e) {
- LOGGER.warn("Something wrong happened while calling consensus layer's
write API.", e);
+ LOGGER.warn("Failed in the write API executing the consensus layer due
to: .", e);
// consensus layer related errors
TSStatus res = new
TSStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR.getStatusCode());
res.setMessage(e.getMessage());
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/cq/CQScheduleTask.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/cq/CQScheduleTask.java
index beb97355496..415afb2ca6f 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/cq/CQScheduleTask.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/cq/CQScheduleTask.java
@@ -252,7 +252,7 @@ public class CQScheduleTask implements Runnable {
.getConsensusManager()
.write(new UpdateCQLastExecTimePlan(cqId, executionTime,
md5));
} catch (ConsensusException e) {
- LOGGER.warn("Something wrong happened while calling consensus
layer's write API.", e);
+ LOGGER.warn("Failed in the write API executing the consensus layer
due to: .", e);
result = new
TSStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR.getStatusCode());
result.setMessage(e.getMessage());
}
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/node/NodeManager.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/node/NodeManager.java
index f226cd6a49f..e8f9e45272a 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/node/NodeManager.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/node/NodeManager.java
@@ -108,7 +108,7 @@ public class NodeManager {
private final ReentrantLock removeConfigNodeLock;
private static final String CONSENSUS_WRITE_ERROR =
- "Something wrong happened while calling consensus layer's write API.";
+ "Failed in the write API executing the consensus layer due to: .";
public NodeManager(IManager configManager, NodeInfo nodeInfo) {
this.configManager = configManager;
@@ -401,7 +401,7 @@ public class NodeManager {
try {
return (DataNodeConfigurationResp) getConsensusManager().read(req);
} catch (ConsensusException e) {
- LOGGER.warn("Something wrong happened while calling consensus layer's
read API.", e);
+ LOGGER.warn("Failed in the read API executing the consensus layer due
to: ", e);
TSStatus res = new
TSStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR.getStatusCode());
res.setMessage(e.getMessage());
DataNodeConfigurationResp response = new DataNodeConfigurationResp();
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/PartitionManager.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/PartitionManager.java
index 5cd736e8c9b..00cfe86e821 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/PartitionManager.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/PartitionManager.java
@@ -131,10 +131,10 @@ public class PartitionManager {
private SeriesPartitionExecutor executor;
private static final String CONSENSUS_READ_ERROR =
- "Something wrong happened while calling consensus layer's read API.";
+ "Failed in the read API executing the consensus layer due to: ";
private static final String CONSENSUS_WRITE_ERROR =
- "Something wrong happened while calling consensus layer's write API.";
+ "Failed in the write API executing the consensus layer due to: .";
/** Region cleaner. */
// Monitor for leadership change
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/plugin/PipePluginCoordinator.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/plugin/PipePluginCoordinator.java
index e13d6a6df01..620aaa27ca2 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/plugin/PipePluginCoordinator.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/plugin/PipePluginCoordinator.java
@@ -101,7 +101,7 @@ public class PipePluginCoordinator {
.read(new GetPipePluginJarPlan(req.getJarNameList())))
.convertToThriftResponse();
} catch (ConsensusException e) {
- LOGGER.warn("Something wrong happened while calling consensus layer's
read API.", e);
+ LOGGER.warn("Failed in the read API executing the consensus layer due
to: ", e);
TSStatus res = new
TSStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR.getStatusCode());
res.setMessage(e.getMessage());
return new JarResp(res,
Collections.emptyList()).convertToThriftResponse();
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/task/PipeTaskCoordinator.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/task/PipeTaskCoordinator.java
index 65dc59b1147..832f6a1a84a 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/task/PipeTaskCoordinator.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/task/PipeTaskCoordinator.java
@@ -146,7 +146,7 @@ public class PipeTaskCoordinator {
.filter(req.whereClause, req.pipeName)
.convertToTShowPipeResp();
} catch (ConsensusException e) {
- LOGGER.warn("Something wrong happened while calling consensus layer's
read API.", e);
+ LOGGER.warn("Failed in the read API executing the consensus layer due
to: ", e);
TSStatus res = new
TSStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR.getStatusCode());
res.setMessage(e.getMessage());
return new PipeTableResp(res,
Collections.emptyList()).convertToTShowPipeResp();
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/schema/ClusterSchemaManager.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/schema/ClusterSchemaManager.java
index d14d4843257..4a8d2c6d7a0 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/schema/ClusterSchemaManager.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/schema/ClusterSchemaManager.java
@@ -115,10 +115,10 @@ public class ClusterSchemaManager {
private final ReentrantLock createDatabaseLock = new ReentrantLock();
private static final String CONSENSUS_READ_ERROR =
- "Something wrong happened while calling consensus layer's read API.";
+ "Failed in the read API executing the consensus layer due to: ";
private static final String CONSENSUS_WRITE_ERROR =
- "Something wrong happened while calling consensus layer's write API.";
+ "Failed in the write API executing the consensus layer due to: .";
public ClusterSchemaManager(
IManager configManager,
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/env/ConfigNodeProcedureEnv.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/env/ConfigNodeProcedureEnv.java
index f6e34cb2518..6d36af6af0d 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/env/ConfigNodeProcedureEnv.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/env/ConfigNodeProcedureEnv.java
@@ -272,7 +272,7 @@ public class ConfigNodeProcedureEnv {
"Remove ConfigNode failed because update ConsensusGroup
peer information failed.");
}
} catch (ConsensusException e) {
- LOG.warn("Something wrong happened while calling consensus layer's write
API.", e);
+ LOG.warn("Failed in the write API executing the consensus layer due to:
.", e);
tsStatus = new
TSStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR.getStatusCode());
tsStatus.setMessage(e.getMessage());
}
@@ -556,7 +556,7 @@ public class ConfigNodeProcedureEnv {
try {
getConsensusManager().write(createRegionGroupsPlan);
} catch (ConsensusException e) {
- LOG.warn("Something wrong happened while calling consensus layer's write
API.", e);
+ LOG.warn("Failed in the write API executing the consensus layer due to:
.", e);
}
}
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/env/DataNodeRemoveHandler.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/env/DataNodeRemoveHandler.java
index eb4d1e1924b..2b5f63e7c4d 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/env/DataNodeRemoveHandler.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/env/DataNodeRemoveHandler.java
@@ -569,7 +569,7 @@ public class DataNodeRemoveHandler {
try {
configManager.getConsensusManager().write(new
RemoveDataNodePlan(removeDataNodes));
} catch (ConsensusException e) {
- LOGGER.warn("Something wrong happened while calling consensus layer's
write API.", e);
+ LOGGER.warn("Failed in the write API executing the consensus layer due
to: .", e);
}
// Adjust maxRegionGroupNum
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/cq/CreateCQProcedure.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/cq/CreateCQProcedure.java
index dc7a65d38c0..248432562c7 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/cq/CreateCQProcedure.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/cq/CreateCQProcedure.java
@@ -66,7 +66,7 @@ public class CreateCQProcedure extends
AbstractNodeProcedure<CreateCQState> {
private long firstExecutionTime;
private static final String CONSENSUS_WRITE_ERROR =
- "Something wrong happened while calling consensus layer's write API.";
+ "Failed in the write API executing the consensus layer due to: .";
public CreateCQProcedure(ScheduledExecutorService executor) {
super();
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/model/CreateModelProcedure.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/model/CreateModelProcedure.java
index f4e0dbb989c..91c47f3a28e 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/model/CreateModelProcedure.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/model/CreateModelProcedure.java
@@ -165,7 +165,7 @@ public class CreateModelProcedure extends
AbstractNodeProcedure<CreateModelState
.getConsensusManager()
.write(new DropModelPlan(modelInformation.getModelId()));
} catch (ConsensusException e) {
- LOGGER.warn("Something wrong happened while calling consensus
layer's write API.", e);
+ LOGGER.warn("Failed in the write API executing the consensus layer
due to: .", e);
}
break;
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/plugin/CreatePipePluginProcedure.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/plugin/CreatePipePluginProcedure.java
index b0fd11933e5..24fa964ee5f 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/plugin/CreatePipePluginProcedure.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/plugin/CreatePipePluginProcedure.java
@@ -168,7 +168,7 @@ public class CreatePipePluginProcedure extends
AbstractNodeProcedure<CreatePipeP
try {
response =
configNodeManager.getConsensusManager().write(createPluginPlan);
} catch (ConsensusException e) {
- LOGGER.warn("Something wrong happened while calling consensus layer's
write API.", e);
+ LOGGER.warn("Failed in the write API executing the consensus layer due
to: .", e);
response = new
TSStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR.getStatusCode());
response.setMessage(e.getMessage());
}
@@ -238,7 +238,7 @@ public class CreatePipePluginProcedure extends
AbstractNodeProcedure<CreatePipeP
.getConsensusManager()
.write(new DropPipePluginPlan(pipePluginMeta.getPluginName()));
} catch (ConsensusException e) {
- LOGGER.warn("Something wrong happened while calling consensus layer's
write API.", e);
+ LOGGER.warn("Failed in the write API executing the consensus layer due
to: .", e);
}
}
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/plugin/DropPipePluginProcedure.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/plugin/DropPipePluginProcedure.java
index f60ff784043..e201afc753b 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/plugin/DropPipePluginProcedure.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/plugin/DropPipePluginProcedure.java
@@ -122,7 +122,7 @@ public class DropPipePluginProcedure extends
AbstractNodeProcedure<DropPipePlugi
try {
env.getConfigManager().getConsensusManager().write(new
DropPipePluginPlan(pluginName));
} catch (ConsensusException e) {
- LOGGER.warn("Something wrong happened while calling consensus layer's
write API.", e);
+ LOGGER.warn("Failed in the write API executing the consensus layer due
to: .", e);
}
setNextState(DropPipePluginState.DROP_ON_DATA_NODES);
@@ -149,7 +149,7 @@ public class DropPipePluginProcedure extends
AbstractNodeProcedure<DropPipePlugi
try {
env.getConfigManager().getConsensusManager().write(new
DropPipePluginPlan(pluginName));
} catch (ConsensusException e) {
- LOGGER.warn("Something wrong happened while calling consensus layer's
write API.", e);
+ LOGGER.warn("Failed in the write API executing the consensus layer due
to: .", e);
}
setNextState(DropPipePluginState.UNLOCK);
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/runtime/PipeHandleLeaderChangeProcedure.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/runtime/PipeHandleLeaderChangeProcedure.java
index 7536b822793..de003728800 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/runtime/PipeHandleLeaderChangeProcedure.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/runtime/PipeHandleLeaderChangeProcedure.java
@@ -97,7 +97,7 @@ public class PipeHandleLeaderChangeProcedure extends
AbstractOperatePipeProcedur
try {
response =
env.getConfigManager().getConsensusManager().write(pipeHandleLeaderChangePlan);
} catch (ConsensusException e) {
- LOGGER.warn("Something wrong happened while calling consensus layer's
write API.", e);
+ LOGGER.warn("Failed in the write API executing the consensus layer due
to: .", e);
response = new
TSStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR.getStatusCode());
response.setMessage(e.getMessage());
}
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/runtime/PipeHandleMetaChangeProcedure.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/runtime/PipeHandleMetaChangeProcedure.java
index eb32e30281b..6ff376cd19d 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/runtime/PipeHandleMetaChangeProcedure.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/runtime/PipeHandleMetaChangeProcedure.java
@@ -98,7 +98,7 @@ public class PipeHandleMetaChangeProcedure extends
AbstractOperatePipeProcedureV
.getConsensusManager()
.write(new PipeHandleMetaChangePlan(pipeMetaList));
} catch (ConsensusException e) {
- LOGGER.warn("Something wrong happened while calling consensus layer's
write API.", e);
+ LOGGER.warn("Failed in the write API executing the consensus layer due
to: .", e);
response = new
TSStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR.getStatusCode());
response.setMessage(e.getMessage());
}
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/CreatePipeProcedureV2.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/CreatePipeProcedureV2.java
index 12db604916a..ad1d117e208 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/CreatePipeProcedureV2.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/CreatePipeProcedureV2.java
@@ -136,7 +136,7 @@ public class CreatePipeProcedureV2 extends
AbstractOperatePipeProcedureV2 {
.getConsensusManager()
.write(new CreatePipePlanV2(pipeStaticMeta, pipeRuntimeMeta));
} catch (ConsensusException e) {
- LOGGER.warn("Something wrong happened while calling consensus layer's
write API.", e);
+ LOGGER.warn("Failed in the write API executing the consensus layer due
to: .", e);
response = new
TSStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR.getStatusCode());
response.setMessage(e.getMessage());
}
@@ -191,7 +191,7 @@ public class CreatePipeProcedureV2 extends
AbstractOperatePipeProcedureV2 {
.getConsensusManager()
.write(new DropPipePlanV2(createPipeRequest.getPipeName()));
} catch (ConsensusException e) {
- LOGGER.warn("Something wrong happened while calling consensus layer's
write API.", e);
+ LOGGER.warn("Failed in the write API executing the consensus layer due
to: .", e);
response = new
TSStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR.getStatusCode());
response.setMessage(e.getMessage());
}
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/DropPipeProcedureV2.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/DropPipeProcedureV2.java
index 19a8af9cd1b..492d3dc36d9 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/DropPipeProcedureV2.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/DropPipeProcedureV2.java
@@ -79,7 +79,7 @@ public class DropPipeProcedureV2 extends
AbstractOperatePipeProcedureV2 {
try {
response = env.getConfigManager().getConsensusManager().write(new
DropPipePlanV2(pipeName));
} catch (ConsensusException e) {
- LOGGER.warn("Something wrong happened while calling consensus layer's
write API.", e);
+ LOGGER.warn("Failed in the write API executing the consensus layer due
to: .", e);
response = new
TSStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR.getStatusCode());
response.setMessage(e.getMessage());
}
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/StartPipeProcedureV2.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/StartPipeProcedureV2.java
index 070bc20058b..fbb97c403b2 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/StartPipeProcedureV2.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/StartPipeProcedureV2.java
@@ -83,7 +83,7 @@ public class StartPipeProcedureV2 extends
AbstractOperatePipeProcedureV2 {
.getConsensusManager()
.write(new SetPipeStatusPlanV2(pipeName, PipeStatus.RUNNING));
} catch (ConsensusException e) {
- LOGGER.warn("Something wrong happened while calling consensus layer's
write API.", e);
+ LOGGER.warn("Failed in the write API executing the consensus layer due
to: .", e);
response = new
TSStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR.getStatusCode());
response.setMessage(e.getMessage());
}
@@ -132,7 +132,7 @@ public class StartPipeProcedureV2 extends
AbstractOperatePipeProcedureV2 {
.getConsensusManager()
.write(new SetPipeStatusPlanV2(pipeName, PipeStatus.STOPPED));
} catch (ConsensusException e) {
- LOGGER.warn("Something wrong happened while calling consensus layer's
write API.", e);
+ LOGGER.warn("Failed in the write API executing the consensus layer due
to: .", e);
response = new
TSStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR.getStatusCode());
response.setMessage(e.getMessage());
}
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/StopPipeProcedureV2.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/StopPipeProcedureV2.java
index c624c36a42f..3dae839da77 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/StopPipeProcedureV2.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/StopPipeProcedureV2.java
@@ -83,7 +83,7 @@ public class StopPipeProcedureV2 extends
AbstractOperatePipeProcedureV2 {
.getConsensusManager()
.write(new SetPipeStatusPlanV2(pipeName, PipeStatus.STOPPED));
} catch (ConsensusException e) {
- LOGGER.warn("Something wrong happened while calling consensus layer's
write API.", e);
+ LOGGER.warn("Failed in the write API executing the consensus layer due
to: .", e);
response = new
TSStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR.getStatusCode());
response.setMessage(e.getMessage());
}
@@ -128,7 +128,7 @@ public class StopPipeProcedureV2 extends
AbstractOperatePipeProcedureV2 {
.getConsensusManager()
.write(new SetPipeStatusPlanV2(pipeName, PipeStatus.RUNNING));
} catch (ConsensusException e) {
- LOGGER.warn("Something wrong happened while calling consensus layer's
write API.", e);
+ LOGGER.warn("Failed in the write API executing the consensus layer due
to: .", e);
response = new
TSStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR.getStatusCode());
response.setMessage(e.getMessage());
}
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/SetTemplateProcedure.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/SetTemplateProcedure.java
index f58aae993f9..a65d1e1e272 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/SetTemplateProcedure.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/SetTemplateProcedure.java
@@ -80,7 +80,7 @@ public class SetTemplateProcedure
private String templateSetPath;
private static final String CONSENSUS_WRITE_ERROR =
- "Something wrong happened while calling consensus layer's write API.";
+ "Failed in the write API executing the consensus layer due to: .";
public SetTemplateProcedure() {
super();
@@ -158,7 +158,7 @@ public class SetTemplateProcedure
(TemplateInfoResp)
env.getConfigManager().getConsensusManager().read(checkTemplateSettablePlan);
} catch (ConsensusException e) {
- LOGGER.warn("Something wrong happened while calling consensus layer's
read API.", e);
+ LOGGER.warn("Failed in the read API executing the consensus layer due
to: ", e);
TSStatus res = new
TSStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR.getStatusCode());
res.setMessage(e.getMessage());
resp = new TemplateInfoResp();
@@ -236,7 +236,7 @@ public class SetTemplateProcedure
(TemplateInfoResp)
env.getConfigManager().getConsensusManager().read(getSchemaTemplatePlan);
} catch (ConsensusException e) {
- LOGGER.warn("Something wrong happened while calling consensus layer's
read API.", e);
+ LOGGER.warn("Failed in the read API executing the consensus layer due
to: ", e);
TSStatus res = new
TSStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR.getStatusCode());
res.setMessage(e.getMessage());
templateResp = new TemplateInfoResp();
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/statemachine/CreateRegionGroupsProcedure.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/statemachine/CreateRegionGroupsProcedure.java
index b709a1f00bd..e18c45c4ee6 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/statemachine/CreateRegionGroupsProcedure.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/statemachine/CreateRegionGroupsProcedure.java
@@ -165,7 +165,7 @@ public class CreateRegionGroupsProcedure
try {
env.getConfigManager().getConsensusManager().write(offerPlan);
} catch (ConsensusException e) {
- LOGGER.warn("Something wrong happened while calling consensus
layer's write API.", e);
+ LOGGER.warn("Failed in the write API executing the consensus layer
due to: .", e);
}
setNextState(CreateRegionGroupsState.ACTIVATE_REGION_GROUPS);
break;
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/trigger/CreateTriggerProcedure.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/trigger/CreateTriggerProcedure.java
index 8410680fa61..4ccce136c0e 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/trigger/CreateTriggerProcedure.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/trigger/CreateTriggerProcedure.java
@@ -198,7 +198,7 @@ public class CreateTriggerProcedure extends
AbstractNodeProcedure<CreateTriggerS
.getConsensusManager()
.write(new
DeleteTriggerInTablePlan(triggerInformation.getTriggerName()));
} catch (ConsensusException e) {
- LOG.warn("Something wrong happened while calling consensus layer's
write API.", e);
+ LOG.warn("Failed in the write API executing the consensus layer due
to: .", e);
}
break;
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/store/ConfigProcedureStore.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/store/ConfigProcedureStore.java
index ba535ff11fc..5f5ab388c55 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/store/ConfigProcedureStore.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/store/ConfigProcedureStore.java
@@ -84,7 +84,7 @@ public class ConfigProcedureStore implements IProcedureStore {
try {
getConsensusManager().write(updateProcedurePlan);
} catch (ConsensusException e) {
- LOG.warn("Something wrong happened while calling consensus layer's write
API.", e);
+ LOG.warn("Failed in the write API executing the consensus layer due to:
.", e);
}
}
@@ -102,7 +102,7 @@ public class ConfigProcedureStore implements
IProcedureStore {
try {
getConsensusManager().write(deleteProcedurePlan);
} catch (ConsensusException e) {
- LOG.warn("Something wrong happened while calling consensus layer's write
API.", e);
+ LOG.warn("Failed in the write API executing the consensus layer due to:
.", e);
}
}
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/executor/RegionWriteExecutor.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/executor/RegionWriteExecutor.java
index 152cbe07928..84c27a35a2d 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/executor/RegionWriteExecutor.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/executor/RegionWriteExecutor.java
@@ -169,7 +169,7 @@ public class RegionWriteExecutor {
response.setMessage(status.getMessage());
response.setStatus(status);
} catch (ConsensusException e) {
- LOGGER.error("Something wrong happened while calling consensus layer's
write API.", e);
+ LOGGER.error("Failed in the write API executing the consensus layer
due to: .", e);
response.setAccepted(false);
response.setMessage(e.toString());
response.setStatus(
@@ -230,7 +230,7 @@ public class RegionWriteExecutor {
}
return response;
} catch (ConsensusException e) {
- LOGGER.warn("Something wrong happened while calling consensus layer's
write API.", e);
+ LOGGER.warn("Failed in the write API executing the consensus layer due
to: .", e);
response.setAccepted(false);
response.setMessage(e.toString());
response.setStatus(RpcUtils.getStatus(TSStatusCode.WRITE_PROCESS_ERROR,
e.toString()));
