[iotdb] branch improve_wal updated: fix serialization

[jiangtian]

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

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


The following commit(s) were added to refs/heads/improve_wal by this push:
     new 6c2f90a  fix serialization
6c2f90a is described below

commit 6c2f90a6e51c531138558ffef1c7b68412f079b1
Author: jt <jt2594...@163.com>
AuthorDate: Mon Oct 12 21:01:02 2020 +0800

    fix serialization
---
 .../main/java/org/apache/iotdb/db/qp/physical/crud/InsertRowPlan.java | 4 ----
 .../java/org/apache/iotdb/db/qp/physical/crud/InsertTabletPlan.java   | 4 ----
 2 files changed, 8 deletions(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/qp/physical/crud/InsertRowPlan.java 
b/server/src/main/java/org/apache/iotdb/db/qp/physical/crud/InsertRowPlan.java
index d060c12..a077577 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/qp/physical/crud/InsertRowPlan.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/qp/physical/crud/InsertRowPlan.java
@@ -421,10 +421,6 @@ public class InsertRowPlan extends InsertPlan {
 
     putDiffTime(this.getTime(), baseInsertRowPlan.getTime(), buffer);
 
-    buffer
-        .putInt(this.getMeasurements().length - (this.getFailedMeasurements() 
== null ? 0 :
-            this.getFailedMeasurements().size()));
-
     try {
       this.putValues(buffer);
     } catch (QueryProcessException e) {
diff --git 
a/server/src/main/java/org/apache/iotdb/db/qp/physical/crud/InsertTabletPlan.java
 
b/server/src/main/java/org/apache/iotdb/db/qp/physical/crud/InsertTabletPlan.java
index ef1fd77..f335a57 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/qp/physical/crud/InsertTabletPlan.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/qp/physical/crud/InsertTabletPlan.java
@@ -190,10 +190,6 @@ public class InsertTabletPlan extends InsertPlan {
     int type = PhysicalPlanType.BATCHINSERT.ordinal();
     buffer.put((byte) type);
 
-    buffer
-        .putInt(this.getMeasurements().length - (this.getFailedMeasurements() 
== null ? 0 :
-            this.getFailedMeasurements().size()));
-
     serializeTimeValue(buffer);
   }