[iotdb] 01/01: add test codes for ty lose data

[hxd]

This is an automated email from the ASF dual-hosted git repository.

hxd pushed a commit to branch check_lost_data_ty
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit 63680e3e82813c1001181f1f42e9dedeead99a01
Author: xiangdong huang <saint...@gmail.com>
AuthorDate: Thu Jul 22 11:52:03 2021 +0800

    add test codes for ty lose data
---
 .../db/qp/physical/crud/InsertRowsOfOneDevicePlan.java     | 14 +++++++++++++-
 1 file changed, 13 insertions(+), 1 deletion(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/qp/physical/crud/InsertRowsOfOneDevicePlan.java
 
b/server/src/main/java/org/apache/iotdb/db/qp/physical/crud/InsertRowsOfOneDevicePlan.java
index 15f667b..16a6dc4 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/qp/physical/crud/InsertRowsOfOneDevicePlan.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/qp/physical/crud/InsertRowsOfOneDevicePlan.java
@@ -31,9 +31,12 @@ import java.util.ArrayList;
 import java.util.HashSet;
 import java.util.List;
 import java.util.Set;
+import org.apache.iotdb.tsfile.utils.Binary;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 public class InsertRowsOfOneDevicePlan extends InsertPlan implements BatchPlan 
{
-
+  private static Logger logger = 
LoggerFactory.getLogger(InsertRowsOfOneDevicePlan.class);
   boolean[] isExecuted;
   private InsertRowPlan[] rowPlans;
 
@@ -64,6 +67,15 @@ public class InsertRowsOfOneDevicePlan extends InsertPlan 
implements BatchPlan {
                 + ", time:"
                 + insertTimes[i]);
       }
+      //Just for Tianyuan debug
+      for(int j = 0; j < rowPlans[i].getMeasurements().length; j ++) {
+        if (rowPlans[i].getMeasurements()[j].equals("TY_0001_Raw_Packet")) {
+          String value = ((Binary) 
rowPlans[i].getValues()[j]).getStringValue().substring(0,100);
+          if 
(value.contains(rowPlans[i].getDeviceId().getTailNode().substring(4))) {
+            logger.error("receive error data，device:{}, value（first 100 
bytes）: {}", rowPlans[i].getDeviceId(), value);
+          }
+        }
+      }
     }
   }