[incubator-iotdb] 02/02: add log

[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;