[iotdb] branch check_lost_data_ty created (now 63680e3)

[hx...@apache.org]

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

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


      at 63680e3  add test codes for ty lose data

This branch includes the following new commits:

     new 63680e3  add test codes for ty lose data

The 1 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.

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

[hx...@apache.org]

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 <sa...@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);
+          }
+        }
+      }
     }
   }