You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by yu...@apache.org on 2020/10/26 06:32:37 UTC
[iotdb] branch kyy updated: final
This is an automated email from the ASF dual-hosted git repository.
yuyuankang pushed a commit to branch kyy
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/kyy by this push:
new d1f91d9 final
d1f91d9 is described below
commit d1f91d998dede8b2e8addc5839452e5cdc79b472
Author: Ring-k <yu...@hotmail.com>
AuthorDate: Mon Oct 26 14:32:00 2020 +0800
final
---
.../src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java b/server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java
index ba49652..2842eb4 100644
--- a/server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java
+++ b/server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java
@@ -158,6 +158,8 @@ public class PlanExecutor implements IPlanExecutor {
// for administration
private IAuthorizer authorizer;
+ private final String INSERT_MEASUREMENTS_FAILED_MESSAGE = "failed to insert measurements ";
+
public PlanExecutor() throws QueryProcessException {
queryRouter = new QueryRouter();
try {
@@ -950,7 +952,7 @@ public class PlanExecutor implements IPlanExecutor {
throw new PathNotExistException(failedPaths);
} else {
throw new StorageEngineException(
- "failed to insert measurements " + insertRowPlan.getFailedMeasurements());
+ INSERT_MEASUREMENTS_FAILED_MESSAGE + insertRowPlan.getFailedMeasurements());
}
}
} catch (StorageEngineException | MetadataException e) {
@@ -967,7 +969,7 @@ public class PlanExecutor implements IPlanExecutor {
StorageEngine.getInstance().insertTablet(insertTabletPlan);
if (insertTabletPlan.getFailedMeasurements() != null) {
throw new StorageEngineException(
- "failed to insert measurements " + insertTabletPlan.getFailedMeasurements());
+ INSERT_MEASUREMENTS_FAILED_MESSAGE + insertTabletPlan.getFailedMeasurements());
}
} catch (StorageEngineException | MetadataException e) {
throw new QueryProcessException(e);