[incubator-iotdb] branch debug_plan_executor updated: add log

[qiaojialin]

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


The following commit(s) were added to refs/heads/debug_plan_executor by this 
push:
     new a410dfd  add log
a410dfd is described below

commit a410dfdb86baac4adafcabf91d4682928e5be9d6
Author: qiaojialin <646274...@qq.com>
AuthorDate: Tue Jun 2 16:12:01 2020 +0800

    add log
---
 server/src/main/java/org/apache/iotdb/db/metadata/MTree.java       | 7 +++++++
 .../main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java    | 5 +++--
 2 files changed, 10 insertions(+), 2 deletions(-)

diff --git a/server/src/main/java/org/apache/iotdb/db/metadata/MTree.java 
b/server/src/main/java/org/apache/iotdb/db/metadata/MTree.java
index 4551f0a..7d779d0 100644
--- a/server/src/main/java/org/apache/iotdb/db/metadata/MTree.java
+++ b/server/src/main/java/org/apache/iotdb/db/metadata/MTree.java
@@ -59,10 +59,14 @@ import 
org.apache.iotdb.tsfile.file.metadata.enums.TSEncoding;
 import org.apache.iotdb.tsfile.read.common.Path;
 import org.apache.iotdb.tsfile.utils.Pair;
 import org.apache.iotdb.tsfile.write.schema.MeasurementSchema;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 /** The hierarchical struct of the Metadata Tree is implemented in this class. 
*/
 public class MTree implements Serializable {
 
+  private static final Logger logger = LoggerFactory.getLogger(MTree.class);
+
   private static final long serialVersionUID = -4200394435237291964L;
   private MNode root;
 
@@ -115,10 +119,13 @@ public class MTree implements Serializable {
       cur = cur.getChild(nodeName);
     }
     if (cur instanceof LeafMNode) {
+      logger.warn("ready to throw PathAlreadyExistException {}", 
cur.getFullPath());
       throw new PathAlreadyExistException(cur.getFullPath());
     }
     String leafName = nodeNames[nodeNames.length - 1];
     if (cur.hasChild(leafName)) {
+      logger.warn("ready to throw PathAlreadyExistException, cur node {} has 
child {}", cur.getFullPath(), leafName);
+      logger.warn("cur node {} has children {}", cur.getFullPath(), 
cur.getChildren().keySet());
       throw new PathAlreadyExistException(path);
     }
     if (alias != null && cur.hasChild(alias)) {
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 05d46f1..1c0ba62 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
@@ -893,6 +893,7 @@ public class PlanExecutor implements IPlanExecutor {
           LeafMNode measurementNode = (LeafMNode) node.getChild(measurement);
           if (measurementNode == null) {
             logger.warn("LeafMNode {} does not exist of device {}", 
measurement, deviceId);
+            logger.warn("DeviceNode {} has children {}", deviceId, 
node.getChildren().keySet());
           }
           schemas[i] = measurementNode.getSchema();
           // reset measurement to common name instead of alias
@@ -985,8 +986,8 @@ public class PlanExecutor implements IPlanExecutor {
 //      if (logger.isDebugEnabled()) {
         logger.warn(
             "Ignore PathAlreadyExistException when Concurrent inserting"
-                + " a non-exist time series {}",
-            path);
+                + " a non-exist time series {}, exception message {}",
+            path, e.getMessage());
 //      }
     }
   }