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:28 UTC
[incubator-iotdb] 01/02: add log
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();