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 2020/06/02 07:57:27 UTC
[incubator-iotdb] branch debug_plan_executor created (now f981a68)
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a change to branch debug_plan_executor
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.
at f981a68 add log
This branch includes the following new commits:
new e65acf5 add log
new f981a68 add log
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[incubator-iotdb] 02/02: add log
Posted by qi...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a commit to branch debug_plan_executor
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
commit f981a682ce0fb435d38e55e30ce332e970fdecb0
Author: qiaojialin <64...@qq.com>
AuthorDate: Tue Jun 2 15:57:01 2020 +0800
add log
---
.../main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java | 9 +++++----
.../java/org/apache/iotdb/db/qp/physical/crud/InsertPlan.java | 1 +
2 files changed, 6 insertions(+), 4 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 f0e8b1c..05d46f1 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
@@ -873,6 +873,7 @@ public class PlanExecutor implements IPlanExecutor {
try {
String[] measurementList = insertPlan.getMeasurements();
String deviceId = insertPlan.getDeviceId();
+ logger.warn("start to insert device {} and measurements {}", deviceId, Arrays.asList(measurementList));
node = mManager.getDeviceNodeWithAutoCreateAndReadLock(deviceId);
MeasurementSchema[] schemas = new MeasurementSchema[measurementList.length];
@@ -887,7 +888,7 @@ public class PlanExecutor implements IPlanExecutor {
.getPredictedDataType(insertPlan.getValues()[i], insertPlan.isInferType());
Path path = new Path(deviceId, measurement);
internalCreateTimeseries(path.toString(), dataType);
- logger.warn("created non-exist path {}", path.toString());
+ logger.warn("created non-exist path {}, value {}, datatype {}", path.toString(), dataType);
}
LeafMNode measurementNode = (LeafMNode) node.getChild(measurement);
if (measurementNode == null) {
@@ -981,12 +982,12 @@ public class PlanExecutor implements IPlanExecutor {
TSFileDescriptor.getInstance().getConfig().getCompressor(),
Collections.emptyMap());
} catch (PathAlreadyExistException e) {
- if (logger.isDebugEnabled()) {
- logger.debug(
+// if (logger.isDebugEnabled()) {
+ logger.warn(
"Ignore PathAlreadyExistException when Concurrent inserting"
+ " a non-exist time series {}",
path);
- }
+// }
}
}
diff --git a/server/src/main/java/org/apache/iotdb/db/qp/physical/crud/InsertPlan.java b/server/src/main/java/org/apache/iotdb/db/qp/physical/crud/InsertPlan.java
index c28095c..c793558 100644
--- a/server/src/main/java/org/apache/iotdb/db/qp/physical/crud/InsertPlan.java
+++ b/server/src/main/java/org/apache/iotdb/db/qp/physical/crud/InsertPlan.java
@@ -204,6 +204,7 @@ public class InsertPlan extends PhysicalPlan {
failedMeasurements = new ArrayList<>();
}
failedMeasurements.add(measurements[index]);
+ logger.warn("mark index {} of measurement {} as null", index, measurements[index]);
schemas[index] = null;
measurements[index] = null;
types[index] = null;
[incubator-iotdb] 01/02: add log
Posted by qi...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a commit to branch debug_plan_executor
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
commit e65acf53e266ddb4fe8b0b6b8db5d2bcb508c1a8
Author: qiaojialin <64...@qq.com>
AuthorDate: Tue Jun 2 15:18:34 2020 +0800
add log
---
.../src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java | 6 ++++++
1 file changed, 6 insertions(+)
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 f3be36d..f0e8b1c 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
@@ -79,6 +79,7 @@ import org.apache.iotdb.db.metadata.mnode.InternalMNode;
import org.apache.iotdb.db.metadata.mnode.LeafMNode;
import org.apache.iotdb.db.metadata.mnode.MNode;
import org.apache.iotdb.db.metadata.mnode.StorageGroupMNode;
+import org.apache.iotdb.db.qp.constant.SQLConstant;
import org.apache.iotdb.db.qp.logical.Operator.OperatorType;
import org.apache.iotdb.db.qp.logical.sys.AuthorOperator;
import org.apache.iotdb.db.qp.logical.sys.AuthorOperator.AuthorType;
@@ -126,6 +127,7 @@ import org.apache.iotdb.db.utils.TypeInferenceUtils;
import org.apache.iotdb.db.utils.UpgradeUtils;
import org.apache.iotdb.service.rpc.thrift.TSStatus;
import org.apache.iotdb.tsfile.common.conf.TSFileDescriptor;
+import org.apache.iotdb.tsfile.common.constant.TsFileConstant;
import org.apache.iotdb.tsfile.exception.filter.QueryFilterOptimizationException;
import org.apache.iotdb.tsfile.exception.write.UnSupportedDataTypeException;
import org.apache.iotdb.tsfile.file.metadata.ChunkGroupMetadata;
@@ -885,8 +887,12 @@ public class PlanExecutor implements IPlanExecutor {
.getPredictedDataType(insertPlan.getValues()[i], insertPlan.isInferType());
Path path = new Path(deviceId, measurement);
internalCreateTimeseries(path.toString(), dataType);
+ logger.warn("created non-exist path {}", path.toString());
}
LeafMNode measurementNode = (LeafMNode) node.getChild(measurement);
+ if (measurementNode == null) {
+ logger.warn("LeafMNode {} does not exist of device {}", measurement, deviceId);
+ }
schemas[i] = measurementNode.getSchema();
// reset measurement to common name instead of alias
measurementList[i] = measurementNode.getName();